Enum LateEventDecision 

pub enum LateEventDecision {
    Drop,
    Process(StreamEvent),
    SideOutput(StreamEvent),
    Recompute(StreamEvent),
}

Decision for how to handle a late event

Variants

Drop

Drop the event

Process(StreamEvent)

Process the event normally

SideOutput(StreamEvent)

Route to side output

Recompute(StreamEvent)

Recompute affected windows

Trait Implementations

impl Clone for LateEventDecision

fn clone(&self) -> LateEventDecision

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LateEventDecision

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

Formats the value using the given formatter.