Struct rlink::functions::watermark::watermarks_with_idleness::WatermarksWithIdleness

pub struct WatermarksWithIdleness { /* fields omitted */ }

A WatermarkGenerator that adds idleness detection to another WatermarkGenerator. If no events come within a certain time (timeout duration) then this generator marks the stream as idle, until the next watermark is generated.

Reference: org.apache.flink.api.common.eventtime.WatermarksWithIdleness

Implementations

impl WatermarksWithIdleness

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

Trait Implementations

impl Debug for WatermarksWithIdleness

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

Formats the value using the given formatter.

impl WatermarkGenerator for WatermarksWithIdleness

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.