Module window

Module window 

Source
Expand description

Window management for event processing

This module provides windowing capabilities for stream processing including:

  • Time-based windowing (tumbling, sliding)
  • Count-based windowing
  • Session-based windowing
  • Custom window types

Structs§

EventWindow
Event processing window
Watermark
Watermark for tracking event time progress
WindowConfig
Window configuration
WindowResult
Result of window aggregation

Enums§

WindowTrigger
Window trigger conditions
WindowType
Window types for event processing