Struct rlink::core::watermark::Watermark [−][src]
pub struct Watermark { /* fields omitted */ }
Expand description
Watermarks are the progress indicators in the data streams. A watermark signifies that no events with a timestamp smaller or equal to the watermark’s time will occur after the water. A watermark with timestamp T indicates that the stream’s event time has progressed to time T.
Watermarks are created at the WatermarkAssigner
and propagate through the streams and
operators.
Note: A stream’s time starts with a watermark of 0u64
.
Implementations
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Watermark
impl UnwindSafe for Watermark
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn clone_any_send(&self) -> Box<dyn CloneAny + Send + 'static, Global> where
T: Send,
pub fn clone_any_sync(&self) -> Box<dyn CloneAny + Sync + 'static, Global> where
T: Sync,
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self