Struct rlink::functions::watermark::time_periodic_watermarks::TimePeriodicWatermarks

pub struct TimePeriodicWatermarks { /* fields omitted */ }

Determine whether to generate watermark based on the rate of processing time and event time

check condition: event_timestamp(n) - event_timestamp(m) > event_period, (n > m) trigger condition: process_timestamp(n) - process_timestamp(m) < process_period

Implementations

impl TimePeriodicWatermarks

pub fn new(
    watermarks: Box<dyn WatermarkGenerator>,
    process_period: Duration,
    event_period: Duration
) -> Self

Trait Implementations

impl Debug for TimePeriodicWatermarks

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

Formats the value using the given formatter.

impl WatermarkGenerator for TimePeriodicWatermarks

fn on_event(
    &mut self,
    record: &mut Record,
    event_timestamp: u64
) -> Option<Watermark>

Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.

fn on_periodic_emit(&mut self) -> Option<Watermark>

Called periodically, and might emit a new watermark, or not.