Expand description
Window assignment, emit strategies, and CDC types for stream processing.
TumblingWindowAssigner: Fixed-size, non-overlapping windowsEmitStrategy: Controls when window results are emittedChangelogRecord: CDC records with Z-set weights
Structs§
- Changelog
Record - Changelog record with Z-set weight for CDC pipelines.
- Tumbling
Window Assigner - Tumbling window assigner: fixed-size, non-overlapping windows aligned to epoch.
- Window
Id - Unique identifier for a window (start inclusive, end exclusive, milliseconds).
Enums§
- CdcOperation
- CDC operation type with Z-set weights.
- Emit
Strategy - Strategy for when window results should be emitted.
Traits§
- Window
Assigner - Trait for assigning events to windows.
Type Aliases§
- Window
IdVec - Window assignment results. Inline storage for up to 4 windows (avoids heap).