Trait rlink::core::watermark::WatermarkStrategy

pub trait WatermarkStrategy: NamedFunction + CheckpointFunction + Debug {
    fn create_watermark_generator(&mut self) -> Box<dyn WatermarkGenerator>;
    fn create_timestamp_assigner(&mut self) -> Box<dyn TimestampAssigner>;
}

The WatermarkStrategy defines how to generate Watermarks in the stream sources. The WatermarkStrategy is a builder/factory for the WatermarkGenerator that generates the watermarks and the TimestampAssigner which assigns the internal timestamp of a record.

Required methods

fn create_watermark_generator(&mut self) -> Box<dyn WatermarkGenerator>

Instantiates a WatermarkGenerator that generates watermarks according to this strategy.

fn create_timestamp_assigner(&mut self) -> Box<dyn TimestampAssigner>

Instantiates a TimestampAssigner for assigning timestamps according to this strategy.

Implementors

impl WatermarkStrategy for DefaultWatermarkStrategy