Enum LateDataPolicy 

pub enum LateDataPolicy {
    Drop,
    SideOutput,
    AllowLateness(Duration),
}

Policy for handling late data (elements arriving after window closes).

Variants

Drop

Drop late elements silently.

SideOutput

Emit late elements to a side output.

AllowLateness(Duration)

Include late elements in the window (refire if already fired).

Trait Implementations

impl Clone for LateDataPolicy

fn clone(&self) -> LateDataPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LateDataPolicy

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

Formats the value using the given formatter.

impl Default for LateDataPolicy

fn default() -> LateDataPolicy

Returns the “default value” for a type.

impl PartialEq for LateDataPolicy

fn eq(&self, other: &LateDataPolicy) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for LateDataPolicy

impl Eq for LateDataPolicy

impl StructuralPartialEq for LateDataPolicy