Expand description
Streaming operator types and window assigners for stream processing.
Modules§
- sliding_
window - Sliding (hopping) window assigner.
- table_
cache - LRU cache and Xor filter for reference table partial-cache mode.
- window
- Window assignment, emit strategies, and CDC types for stream processing.
Structs§
- Event
- An event flowing through the system.
- Operator
State - Serialized operator state for checkpointing.
Enums§
- Operator
Error - Errors that can occur in operators.
Type Aliases§
- Timer
Key - Timer key type optimized for window IDs (16 bytes).