Struct EventTimeTrigger 

pub struct EventTimeTrigger { /* private fields */ }

Event-time trigger that fires when watermark passes window end.

Implementations

impl EventTimeTrigger

pub fn new() -> Self

Create a new event-time trigger.

Trait Implementations

impl Default for EventTimeTrigger

fn default() -> Self

Returns the “default value” for a type.

impl WindowTrigger for EventTimeTrigger

fn on_element( &mut self, _element: &StreamElement, _window: &Window, _state: &WindowState, ) -> TriggerResult

Called when an element is added to a window.

fn on_processing_time( &mut self, _time: DateTime<Utc>, _window: &Window, ) -> TriggerResult

Called when processing time advances.

fn on_event_time( &mut self, time: DateTime<Utc>, window: &Window, ) -> TriggerResult

Called when event time (watermark) advances.

fn on_merge( &mut self, _window: &Window, _merged_windows: &[Window], ) -> TriggerResult

Called when windows are merged.

fn clear(&mut self)

Clear the trigger state.