Struct MonotonicWatermarkGenerator 

pub struct MonotonicWatermarkGenerator { /* private fields */ }

Generates watermarks that follow the maximum observed timestamp exactly.

This is suitable for streams where events arrive in order.

Implementations

impl MonotonicWatermarkGenerator

pub fn new() -> Self

Creates a new monotonic watermark generator.

Trait Implementations

impl Clone for MonotonicWatermarkGenerator

fn clone(&self) -> MonotonicWatermarkGenerator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MonotonicWatermarkGenerator

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

Formats the value using the given formatter.

impl Default for MonotonicWatermarkGenerator

fn default() -> Self

Returns the “default value” for a type.

impl WatermarkGenerator for MonotonicWatermarkGenerator

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.