Struct EventTimeTrigger 

pub struct EventTimeTrigger;

Default trigger that fires when the watermark passes the window end.

Implementations

impl EventTimeTrigger

pub fn new() -> Self

Creates a new event time trigger.

Trait Implementations

impl Clone for EventTimeTrigger

fn clone(&self) -> EventTimeTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventTimeTrigger

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

Formats the value using the given formatter.

impl Default for EventTimeTrigger

fn default() -> EventTimeTrigger

Returns the “default value” for a type.

impl WindowTrigger<TimeWindow> for EventTimeTrigger

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.