Trait rlink::api::watermark::WatermarkAssigner [−][src]
Required methods
fn watermark(&mut self, stream_status: &StreamStatus) -> Option<Watermark>
[src]
Return the current Watermark
and row's timestamp
fn current_watermark(&self) -> Option<Watermark>
[src]
Implementors
impl<E> WatermarkAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
[src]
E: TimestampAssigner,