Trait rlink::api::watermark::TimestampAssigner [−][src]
Required methods
fn extract_timestamp(
&mut self,
row: &mut Record,
previous_element_timestamp: u64
) -> u64
[src]
&mut self,
row: &mut Record,
previous_element_timestamp: u64
) -> u64
Implementors
impl TimestampAssigner for SchemaBaseTimestampAssigner
[src]
fn extract_timestamp(
&mut self,
row: &mut Record,
_previous_element_timestamp: u64
) -> u64
[src]
&mut self,
row: &mut Record,
_previous_element_timestamp: u64
) -> u64
impl<E> TimestampAssigner for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
[src]
E: TimestampAssigner,
fn extract_timestamp(
&mut self,
row: &mut Record,
previous_element_timestamp: u64
) -> u64
[src]
&mut self,
row: &mut Record,
previous_element_timestamp: u64
) -> u64