Struct PeriodicWatermarkGenerator 

pub struct PeriodicWatermarkGenerator { /* private fields */ }

Generates watermarks at fixed intervals regardless of event arrival.

Implementations

impl PeriodicWatermarkGenerator

pub fn new(max_out_of_orderness: Duration, interval: Duration) -> Self

Creates a new periodic watermark generator.

Trait Implementations

impl Clone for PeriodicWatermarkGenerator

fn clone(&self) -> PeriodicWatermarkGenerator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PeriodicWatermarkGenerator

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

Formats the value using the given formatter.

impl WatermarkGenerator for PeriodicWatermarkGenerator

fn on_event(&mut self, timestamp: DateTime<Utc>) -> Option<Watermark>

Called when a new element arrives with the given event timestamp. Returns the new watermark if it should be emitted.

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

Called periodically to generate watermarks even without new events. Returns the new watermark if it should be emitted.

fn current_watermark(&self) -> Watermark

Returns the current watermark without advancing it.

fn on_end_of_stream(&mut self) -> Watermark

Signals end of stream, generating the final watermark.