Trait rlink::core::watermark::WatermarkGenerator

pub trait WatermarkGenerator: Debug {
    fn on_event(
        &mut self, 
        record: &mut Record, 
        event_timestamp: u64
    ) -> Option<Watermark>;
    fn on_periodic_emit(&mut self) -> Option<Watermark>;
}

Required methods

fn on_event(
    &mut self,
    record: &mut Record,
    event_timestamp: u64
) -> Option<Watermark>

Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.

fn on_periodic_emit(&mut self) -> Option<Watermark>

Called periodically, and might emit a new watermark, or not.

The interval in which this method is called and Watermarks are generated depends on StreamStatus interval

Implementors

impl WatermarkGenerator for BoundedOutOfOrdernessWatermarks

impl WatermarkGenerator for TimePeriodicWatermarks

impl WatermarkGenerator for WatermarksWithIdleness