Struct KeyedWatermarkTrackerWithLateHandling 

pub struct KeyedWatermarkTrackerWithLateHandling<K: Hash + Eq + Clone> { /* private fields */ }

Keyed watermark tracker with late event handling.

Wraps KeyedWatermarkTracker and provides utilities for handling late events, including counting and optional side-output.

Implementations

impl<K: Hash + Eq + Clone> KeyedWatermarkTrackerWithLateHandling<K>

pub fn new(config: KeyedWatermarkConfig) -> Self

Creates a new tracker with late event handling.

pub fn update_with_late_check( &mut self, key: K, event_time: i64, ) -> Result<(Option<Watermark>, bool), KeyedWatermarkError>

Updates the watermark and checks for late events.

Returns (watermark_result, is_late).

Errors

Returns KeyedWatermarkError::MaxKeysReached if the maximum number of keys is reached and the eviction policy is RejectNew.

pub fn late_events_for_key(&self, key: &K) -> u64

Returns late event count for a key.

pub fn total_late_events(&self) -> u64

Returns total late event count.

pub fn inner(&self) -> &KeyedWatermarkTracker<K>

Returns a reference to the inner tracker.

pub fn inner_mut(&mut self) -> &mut KeyedWatermarkTracker<K>

Returns a mutable reference to the inner tracker.

Trait Implementations

impl<K: Debug + Hash + Eq + Clone> Debug for KeyedWatermarkTrackerWithLateHandling<K>

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

Formats the value using the given formatter.