Expand description
Watermark and Late Data Handling
This module provides watermark generation and late data handling for stream processing with out-of-order events.
Structs§
- Late
Data Handler - Handler for late data events
- Late
Data Stats - Statistics about late data handling
- Watermark
- Watermark representing event-time progress
- Watermark
Generator - Watermark generator that tracks event-time progress
- Watermarked
Stream - Watermark-aware stream that tracks event-time progress
Enums§
- Late
Data Strategy - Strategy for handling late events
- Late
Event Decision - Decision for how to handle a late event
- Watermark
Strategy - Strategy for generating watermarks