Struct CompositeTrigger 

pub struct CompositeTrigger { /* private fields */ }

Composite trigger that combines multiple triggers with AND/OR logic

Implementations

impl CompositeTrigger

pub fn any(triggers: Vec<Box<dyn WindowTrigger>>) -> Self

pub fn all(triggers: Vec<Box<dyn WindowTrigger>>) -> Self

Trait Implementations

impl Debug for CompositeTrigger

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

Formats the value using the given formatter.

impl WindowTrigger for CompositeTrigger

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

Evaluate when an element is added to 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

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

Clear any state associated with the window