Struct OnWatermarkTrigger 

pub struct OnWatermarkTrigger;

Trigger that fires when the watermark passes the end of the window

This is the standard trigger for event-time windows. It fires when the watermark (which represents the progress of event time) passes the end of the window, indicating that all events for that window have likely been received.

Implementations

impl OnWatermarkTrigger

pub fn new() -> Self

Trait Implementations

impl Clone for OnWatermarkTrigger

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OnWatermarkTrigger

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

Formats the value using the given formatter.

impl Default for OnWatermarkTrigger

fn default() -> Self

Returns the “default value” for a type.

impl WindowTrigger for OnWatermarkTrigger

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

Evaluate when the watermark advances

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 clear(&mut self, window: &Window)

Clear any state associated with the window