Struct ProcessingTimeTrigger 

pub struct ProcessingTimeTrigger { /* private fields */ }

Trigger that fires after a specified processing time delay

This trigger fires when processing time reaches the window end plus a configured delay. Useful for tumbling and sliding windows based on processing time.

Implementations

impl ProcessingTimeTrigger

pub fn new() -> Self

pub fn with_delay(delay: Duration) -> Self

Trait Implementations

impl Clone for ProcessingTimeTrigger

fn clone(&self) -> ProcessingTimeTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessingTimeTrigger

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

Formats the value using the given formatter.

impl Default for ProcessingTimeTrigger

fn default() -> Self

Returns the “default value” for a type.

impl WindowTrigger for ProcessingTimeTrigger

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

Evaluate when an element is added to the window

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

Evaluate on processing time timer

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

Evaluate when the watermark advances

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

Clear any state associated with the window