Enum WatermarkStrategy 

pub enum WatermarkStrategy {
    BoundedOutOfOrderness {
        max_out_of_orderness: Duration,
    },
}

Strategy for producing watermarks from an event-time column.

Variants

BoundedOutOfOrderness

Emit max_observed_event_time - max_out_of_orderness, monotonically.

Fields

max_out_of_orderness: Duration

Maximum event-time delay tolerated before a row is considered late.

Trait Implementations

impl Clone for WatermarkStrategy

fn clone(&self) -> WatermarkStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatermarkStrategy

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

Formats the value using the given formatter.

impl Eq for WatermarkStrategy

impl PartialEq for WatermarkStrategy

fn eq(&self, other: &WatermarkStrategy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for WatermarkStrategy