Trait WindowTrigger 

pub trait WindowTrigger: Send + Sync {
    // Required methods
    fn on_element(
        &mut self,
        element: &StreamElement,
        window: &Window,
        state: &WindowState,
    ) -> TriggerResult;
    fn on_processing_time(
        &mut self,
        time: DateTime<Utc>,
        window: &Window,
    ) -> TriggerResult;
    fn on_event_time(
        &mut self,
        time: DateTime<Utc>,
        window: &Window,
    ) -> TriggerResult;
    fn on_merge(
        &mut self,
        window: &Window,
        merged_windows: &[Window],
    ) -> TriggerResult;
    fn clear(&mut self);
}

Determines when a window should emit results.

Required Methods

fn on_element( &mut self, element: &StreamElement, window: &Window, state: &WindowState, ) -> TriggerResult

Called when an element is added to a window.

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

Called when processing time advances.

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

Called when event time (watermark) advances.

fn on_merge( &mut self, window: &Window, merged_windows: &[Window], ) -> TriggerResult

Called when windows are merged.

fn clear(&mut self)

Clear the trigger state.

Implementors

impl WindowTrigger for CountTrigger

impl WindowTrigger for EventTimeTrigger