Trait rlink::core::watermark::WatermarkAssigner [−][src]
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>
fn watermark(&mut self, stream_status: &StreamStatus) -> Option<Watermark>
Return the current Watermark
and row’s timestamp