Struct rlink::core::watermark::BoundedOutOfOrdernessTimestampExtractor [−][src]
pub struct BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner, { /* fields omitted */ }
Implementations
Trait Implementations
impl<E> CheckpointFunction for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> CheckpointFunction for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
fn consult_version(
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
trigger the method when a operator
initialization
trigger the method when the operator
operate a Barrier
event
impl<E: Debug> Debug for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E: Debug> Debug for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> NamedFunction for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> NamedFunction for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> TimestampAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> TimestampAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> WatermarkAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
impl<E> WatermarkAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
Return the current Watermark
and row’s timestamp
Auto Trait Implementations
impl<E> RefUnwindSafe for BoundedOutOfOrdernessTimestampExtractor<E> where
E: RefUnwindSafe,
impl<E> Send for BoundedOutOfOrdernessTimestampExtractor<E> where
E: Send,
impl<E> Sync for BoundedOutOfOrdernessTimestampExtractor<E> where
E: Sync,
impl<E> Unpin for BoundedOutOfOrdernessTimestampExtractor<E> where
E: Unpin,
impl<E> UnwindSafe for BoundedOutOfOrdernessTimestampExtractor<E> where
E: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self