Struct CountTrigger 

pub struct CountTrigger { /* private fields */ }

Trigger that fires when a window contains a specified number of elements

This trigger maintains a count per window and fires when the count reaches the threshold. Useful for micro-batching and early window evaluation.

Implementations

impl CountTrigger

pub fn new(threshold: usize) -> Self

Trait Implementations

impl Debug for CountTrigger

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

Formats the value using the given formatter.

impl WindowTrigger for CountTrigger

fn on_element(&mut self, ctx: &TriggerContext) -> TriggerResult

Evaluate when an element is added to the window

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

Clear any state associated with the window

fn on_watermark(&mut self, ctx: &TriggerContext) -> TriggerResult

Evaluate when the watermark advances

fn on_processing_time(&mut self, ctx: &TriggerContext) -> TriggerResult

Evaluate on processing time timer