Trait rlink::api::watermark::TimestampAssigner

pub trait TimestampAssigner where
    Self: NamedFunction + CheckpointFunction + Debug, {
    fn extract_timestamp(
        &mut self, 
        row: &mut Record, 
        previous_element_timestamp: u64
    ) -> u64;
}

Required methods

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

Loading content...

Implementors

impl TimestampAssigner for SchemaBaseTimestampAssigner

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

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

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

Loading content...