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§
- Event
Window - Event processing window
- Watermark
- Watermark for tracking event time progress
- Window
Config - Window configuration
- Window
Result - Result of window aggregation
Enums§
- Window
Trigger - Window trigger conditions
- Window
Type - Window types for event processing