Struct WatermarkGenerator 

pub struct WatermarkGenerator { /* private fields */ }

Watermark generator that tracks event-time progress

Implementations

impl WatermarkGenerator

pub fn new(strategy: WatermarkStrategy) -> Self

Create a new watermark generator with the given strategy

pub fn process_event(&mut self, event: &StreamEvent) -> Option<Watermark>

Process an event and update watermark if needed

pub fn current_watermark(&self) -> Watermark

Get the current watermark

pub fn is_late(&self, event: &StreamEvent) -> bool

Check if an event is late