Struct LateDataHandler 

pub struct LateDataHandler { /* private fields */ }

Handler for late data events

Implementations

impl LateDataHandler

pub fn new(strategy: LateDataStrategy) -> Self

Create a new late data handler with the given strategy

pub fn handle_late_event( &mut self, event: StreamEvent, watermark: &Watermark, ) -> LateEventDecision

Handle a late event according to the strategy

pub fn side_output(&self) -> &[StreamEvent]

Get the side output events

pub fn clear_side_output(&mut self)

Clear the side output

pub fn stats(&self) -> LateDataStats

Get statistics about late events