Struct LateDataHandler 

pub struct LateDataHandler { /* private fields */ }

Handles late data according to the configured policy.

Implementations

impl LateDataHandler

pub fn new(policy: LateDataPolicy) -> Self

Creates a new late data handler with the given policy.

pub fn drop_late() -> Self

Creates a handler that drops all late data.

pub fn with_allowed_lateness(lateness: Duration) -> Self

Creates a handler that allows late data within the given lateness window.

pub fn redirect_to_side_output() -> Self

Creates a handler that redirects late data to a side output.

pub fn evaluate<T>( &mut self, element_timestamp: DateTime<Utc>, current_watermark: &Watermark, element: T, ) -> LateDataResult<T>

Evaluates whether an element is late and returns the appropriate action.

Arguments

• element_timestamp: The event time of the element.
• current_watermark: The current watermark.
• element: The element to evaluate.

pub fn stats(&self) -> &LateDataStats

Returns statistics about late data handling.

pub fn reset_stats(&mut self)

Resets statistics.

pub fn policy(&self) -> &LateDataPolicy

Returns the configured policy.

pub fn get_allowed_lateness(&self) -> Duration

Returns the allowed lateness from the policy.

Trait Implementations

impl Clone for LateDataHandler

fn clone(&self) -> LateDataHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LateDataHandler

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

Formats the value using the given formatter.