Struct CountTrigger 

pub struct CountTrigger { /* private fields */ }

Trigger that fires after a specified count of elements.

Implementations

impl CountTrigger

pub fn new(count: usize) -> Self

Creates a new count trigger that fires after count elements.

pub fn count(&self) -> usize

Returns the target count.

Trait Implementations

impl Clone for CountTrigger

fn clone(&self) -> CountTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CountTrigger

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

Formats the value using the given formatter.

impl WindowTrigger<CountWindow> for CountTrigger

fn on_element( &mut self, _timestamp: DateTime<Utc>, window: &CountWindow, ) -> TriggerResult

Called when an element is added to a window.

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

Called when processing time advances.

fn on_event_time( &mut self, _watermark: DateTime<Utc>, _window: &CountWindow, ) -> TriggerResult

Called when the watermark (event time) advances.

fn clear(&mut self, window: &CountWindow)

Called when the trigger is cleared.

fn clone_trigger(&self) -> Box<dyn WindowTrigger<CountWindow>>

Creates a clone of this trigger.