Trait rlink::api::watermark::WatermarkAssigner

pub trait WatermarkAssigner where
    Self: TimestampAssigner + NamedFunction + Debug, {
    fn watermark(&mut self, stream_status: &StreamStatus) -> Option<Watermark>;
    fn current_watermark(&self) -> Option<Watermark>;
}

Required methods

fn watermark(&mut self, stream_status: &StreamStatus) -> Option<Watermark>

Return the current Watermark and row's timestamp

fn current_watermark(&self) -> Option<Watermark>

Loading content...

Implementors

impl<E> WatermarkAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
    E: TimestampAssigner, 

fn watermark(&mut self, _stream_status: &StreamStatus) -> Option<Watermark>

fn current_watermark(&self) -> Option<Watermark>

Loading content...