Struct CountTrigger 

pub struct CountTrigger { /* private fields */ }

Count-based trigger that fires after a certain number of elements.

Implementations

impl CountTrigger

pub fn of(count: usize) -> Self

Create a new count trigger.

Trait Implementations

impl WindowTrigger for CountTrigger

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.