Struct WatermarkConfig 

pub struct WatermarkConfig {
    pub max_out_of_order_ms: u64,
    pub idle_timeout_ms: Option<u64>,
    pub drop_late_events: bool,
}

Watermark configuration for handling out-of-order events.

Fields

max_out_of_order_ms: u64

Maximum allowed out-of-order delay in milliseconds.

idle_timeout_ms: Option<u64>

Optional idle timeout: emit partial windows after this many ms of silence.

drop_late_events: bool

Whether to silently drop events that arrive beyond the watermark.

Implementations

impl WatermarkConfig

pub fn new(max_out_of_order_ms: u64) -> Self

Create a new WatermarkConfig with the given out-of-order tolerance. Defaults: idle_timeout_ms=None, drop_late_events=false.

pub fn with_idle_timeout(self, timeout_ms: u64) -> Self

Set the idle timeout in milliseconds.

pub fn with_drop_late(self, drop: bool) -> Self

Configure whether late events should be dropped.

pub fn current_watermark(&self, max_event_time_ms: u64) -> u64

Compute the current watermark given the maximum observed event timestamp.

The watermark is max_event_time_ms - max_out_of_order_ms, saturating at zero.

pub fn is_late(&self, event_time_ms: u64, watermark_ms: u64) -> bool

Returns true when event_time_ms is behind the current watermark (late event).

Trait Implementations

impl Clone for WatermarkConfig

fn clone(&self) -> WatermarkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatermarkConfig

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

Formats the value using the given formatter.