Trait WatermarkGenerator 

pub trait WatermarkGenerator: Send + Sync {
    // Required methods
    fn on_event(&mut self, element: &StreamElement) -> Option<Watermark>;
    fn on_periodic_emit(&mut self) -> Option<Watermark>;
    fn current_watermark(&self) -> Watermark;
}

Generates watermarks for a stream.

Required Methods

fn on_event(&mut self, element: &StreamElement) -> Option<Watermark>

Process an element and potentially generate a watermark.

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

Generate a periodic watermark.

fn current_watermark(&self) -> Watermark

Get the current watermark.

Implementors

impl WatermarkGenerator for PeriodicWatermarkGenerator

impl WatermarkGenerator for PunctuatedWatermarkGenerator