Enum WatermarkStrategy 

pub enum WatermarkStrategy {
    Periodic {
        interval: Duration,
    },
    BoundedOutOfOrder {
        max_delay: Duration,
    },
    MonotonicAscending,
    Custom,
}

Strategy for generating watermarks

Variants

Periodic

Periodic watermarks based on processing time

Fields

interval: Duration

Interval between watermark generations

BoundedOutOfOrder

Bounded out-of-orderness: watermark = max_timestamp - max_delay

Fields

max_delay: Duration

Maximum delay for out-of-order events

MonotonicAscending

Monotonic ascending watermarks (no out-of-order tolerance)

Custom

Custom watermark generation function

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.