pub struct KeyedWatermarkTrackerWithLateHandling<K: Hash + Eq + Clone> { /* private fields */ }Expand description
Keyed watermark tracker with late event handling.
Wraps KeyedWatermarkTracker and provides utilities for handling late events,
including counting and optional side-output.
Implementations§
Source§impl<K: Hash + Eq + Clone> KeyedWatermarkTrackerWithLateHandling<K>
impl<K: Hash + Eq + Clone> KeyedWatermarkTrackerWithLateHandling<K>
Sourcepub fn new(config: KeyedWatermarkConfig) -> Self
pub fn new(config: KeyedWatermarkConfig) -> Self
Creates a new tracker with late event handling.
Sourcepub fn update_with_late_check(
&mut self,
key: K,
event_time: i64,
) -> Result<(Option<Watermark>, bool), KeyedWatermarkError>
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.
Sourcepub fn late_events_for_key(&self, key: &K) -> u64
pub fn late_events_for_key(&self, key: &K) -> u64
Returns late event count for a key.
Sourcepub fn total_late_events(&self) -> u64
pub fn total_late_events(&self) -> u64
Returns total late event count.
Sourcepub fn inner(&self) -> &KeyedWatermarkTracker<K>
pub fn inner(&self) -> &KeyedWatermarkTracker<K>
Returns a reference to the inner tracker.
Sourcepub fn inner_mut(&mut self) -> &mut KeyedWatermarkTracker<K>
pub fn inner_mut(&mut self) -> &mut KeyedWatermarkTracker<K>
Returns a mutable reference to the inner tracker.
Trait Implementations§
Auto Trait Implementations§
impl<K> Freeze for KeyedWatermarkTrackerWithLateHandling<K>
impl<K> RefUnwindSafe for KeyedWatermarkTrackerWithLateHandling<K>where
K: RefUnwindSafe,
impl<K> Send for KeyedWatermarkTrackerWithLateHandling<K>where
K: Send,
impl<K> Sync for KeyedWatermarkTrackerWithLateHandling<K>where
K: Sync,
impl<K> Unpin for KeyedWatermarkTrackerWithLateHandling<K>where
K: Unpin,
impl<K> UnsafeUnpin for KeyedWatermarkTrackerWithLateHandling<K>
impl<K> UnwindSafe for KeyedWatermarkTrackerWithLateHandling<K>where
K: UnwindSafe,
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.