Enum LateDataStrategy 

pub enum LateDataStrategy {
    Drop,
    AllowedLateness {
        max_lateness: Duration,
    },
    SideOutput,
    RecomputeWindows,
}

Strategy for handling late events

Variants

Drop

Drop late events completely

AllowedLateness

Allow late events up to a certain lateness threshold

Fields

max_lateness: Duration

Maximum allowed lateness

SideOutput

Route late events to a side output for special processing

RecomputeWindows

Recompute affected windows when late data arrives

Trait Implementations

impl Clone for LateDataStrategy

fn clone(&self) -> LateDataStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LateDataStrategy

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

Formats the value using the given formatter.