Struct BoundedOutOfOrdernessGenerator 

pub struct BoundedOutOfOrdernessGenerator { /* private fields */ }

Watermark = max_timestamp_seen - max_out_of_orderness. on_event ignores timestamps far beyond wall clock for advancement.

Implementations

impl BoundedOutOfOrdernessGenerator

pub fn new(max_out_of_orderness: i64) -> Self

Creates a new generator with the specified maximum out-of-orderness.

Arguments

• max_out_of_orderness - Maximum allowed lateness in milliseconds

pub fn with_max_future_skew(self, skew_ms: i64) -> Self

Sets the future-skew ceiling; <= 0 disables the guard.

pub fn from_duration(max_out_of_orderness: Duration) -> Self

Creates a new generator from a Duration.

pub fn max_out_of_orderness(&self) -> i64

Returns the maximum out-of-orderness in milliseconds.

Trait Implementations

impl WatermarkGenerator for BoundedOutOfOrdernessGenerator

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

Process an event timestamp and potentially emit a new watermark.

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

Called periodically to emit watermarks based on wall-clock time.

fn current_watermark(&self) -> i64

Returns the current watermark value without advancing it.

fn advance_watermark(&mut self, timestamp: i64) -> Option<Watermark>

Advances the watermark to at least the given timestamp from an external source.

fn is_processing_time(&self) -> bool

Whether the watermark is processing-time based (wall clock), rather than derived from the event-time column. Such a watermark lives in a different time domain than the event timestamps, so comparing the two to drop “late” rows would discard every event — callers skip source-side late-filtering when this is true. Defaults to false (event-time generators).