Trait rlink::core::watermark::TimestampAssigner

pub trait TimestampAssigner: Debug {
    fn open(&mut self, context: &Context) -> Result<()>;
    fn extract_timestamp(
        &mut self, 
        row: &mut Record, 
        previous_element_timestamp: u64
    ) -> u64;
}

A TimestampAssigner assigns event time timestamps to elements. These timestamps are used by all functions that operate on event time, for example event time windows.

Timestamps can be an arbitrary u64 value, but all built-in implementations represent it as the milliseconds since the Epoch (midnight, January 1, 1970 UTC).

Required methods

fn open(&mut self, context: &Context) -> Result<()>

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

Assigns a timestamp to an element, in milliseconds since the Epoch. This is independent of any particular time zone or calendar.

Implementors

impl TimestampAssigner for SchemaTimestampAssigner