Struct BoundedOutOfOrdernessGenerator 

pub struct BoundedOutOfOrdernessGenerator { /* private fields */ }

Generates watermarks allowing for bounded out-of-orderness.

The watermark is set to max_observed_timestamp - max_out_of_orderness. This allows events to arrive slightly out of order while still making progress.

Implementations

impl BoundedOutOfOrdernessGenerator

pub fn new(max_out_of_orderness: Duration) -> Self

Creates a new bounded out-of-orderness watermark generator.

Trait Implementations

impl Clone for BoundedOutOfOrdernessGenerator

fn clone(&self) -> BoundedOutOfOrdernessGenerator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BoundedOutOfOrdernessGenerator

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

Formats the value using the given formatter.

impl WatermarkGenerator for BoundedOutOfOrdernessGenerator

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.