Struct ProcessingTimeTrigger 

pub struct ProcessingTimeTrigger { /* private fields */ }

Processing time trigger that fires at regular intervals.

Implementations

impl ProcessingTimeTrigger

pub fn new(interval: Duration) -> Self

Creates a new processing time trigger.

pub fn interval(&self) -> Duration

Returns the trigger interval.

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 WindowTrigger<TimeWindow> for ProcessingTimeTrigger

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

Called when an element is added to a window.

fn on_processing_time( &mut self, time: DateTime<Utc>, window: &TimeWindow, ) -> TriggerResult

Called when processing time advances.

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

Called when the watermark (event time) advances.

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

Called when the trigger is cleared.

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

Creates a clone of this trigger.