Struct BoundedOutOfOrdernessGenerator 

pub struct BoundedOutOfOrdernessGenerator { /* private fields */ }

Watermark generator with bounded out-of-orderness.

Allows events to arrive out of order by up to max_out_of_orderness milliseconds. The watermark is always max_timestamp_seen - max_out_of_orderness.

Example

use laminar_core::time::{BoundedOutOfOrdernessGenerator, WatermarkGenerator, Watermark};

let mut gen = BoundedOutOfOrdernessGenerator::new(100); // 100ms lateness allowed

// First event at t=1000
assert_eq!(gen.on_event(1000), Some(Watermark::new(900)));

// Out-of-order event at t=800 - no watermark advance
assert_eq!(gen.on_event(800), None);

// New max at t=1200
assert_eq!(gen.on_event(1200), Some(Watermark::new(1100)));

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 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.