Struct AscendingTimestampsGenerator 

pub struct AscendingTimestampsGenerator { /* private fields */ }

Watermark generator for strictly ascending timestamps; the watermark equals the current timestamp.

Implementations

impl AscendingTimestampsGenerator

pub fn new() -> Self

Creates a new ascending timestamps generator.

pub fn with_max_future_skew(self, skew_ms: i64) -> Self

Override the future-skew ceiling (0 disables).

Trait Implementations

impl Debug for AscendingTimestampsGenerator

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

Formats the value using the given formatter.

impl Default for AscendingTimestampsGenerator

fn default() -> Self

Returns the “default value” for a type.

impl WatermarkGenerator for AscendingTimestampsGenerator

fn on_event(&mut self, timestamp: i64) -> Option<Watermark>

Process an event timestamp and potentially emit a new watermark.

fn on_periodic(&mut self) -> Option<Watermark>

Called periodically to emit watermarks based on wall-clock time.

fn current_watermark(&self) -> i64

Returns the current watermark value without advancing it.

fn advance_watermark(&mut self, timestamp: i64) -> Option<Watermark>

Advances the watermark to at least the given timestamp from an external source.

fn is_processing_time(&self) -> bool

Whether the watermark is processing-time based (wall clock), rather than derived from the event-time column. Such a watermark lives in a different time domain than the event timestamps, so comparing the two to drop “late” rows would discard every event — callers skip source-side late-filtering when this is true. Defaults to false (event-time generators).