Struct rlink::api::watermark::BoundedOutOfOrdernessTimestampExtractor

pub struct BoundedOutOfOrdernessTimestampExtractor<E> where
    E: TimestampAssigner,  { /* fields omitted */ }

Implementations

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

pub fn new(max_out_of_orderness: Duration, extract_timestamp: E) -> Self

Trait Implementations

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>
)

trigger the method when a operator initialization

fn snapshot_state(
    &mut self,
    _context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>

trigger the method when the operator operate a Barrier event

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

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

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

fn name(&self) -> &str

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

fn extract_timestamp(
    &mut self,
    row: &mut Record,
    previous_element_timestamp: u64
) -> u64

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

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

Return the current Watermark and row’s timestamp

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