Struct SessionTrigger 

pub struct SessionTrigger { /* private fields */ }

Trigger that fires when the session gap timeout expires.

Implementations

impl SessionTrigger

pub fn new() -> Self

Creates a new session trigger.

Trait Implementations

impl Clone for SessionTrigger

fn clone(&self) -> SessionTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionTrigger

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

Formats the value using the given formatter.

impl Default for SessionTrigger

fn default() -> Self

Returns the “default value” for a type.

impl WindowTrigger<SessionWindow> for SessionTrigger

fn on_element( &mut self, timestamp: DateTime<Utc>, window: &SessionWindow, ) -> TriggerResult

Called when an element is added to a window.

fn on_processing_time( &mut self, _time: DateTime<Utc>, _window: &SessionWindow, ) -> TriggerResult

Called when processing time advances.

fn on_event_time( &mut self, watermark: DateTime<Utc>, window: &SessionWindow, ) -> TriggerResult

Called when the watermark (event time) advances.

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

Called when the trigger is cleared.

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

Creates a clone of this trigger.