Struct PunctuatedWatermark 

pub struct PunctuatedWatermark { /* private fields */ }

Punctuated watermark generator

Emits watermarks based on specific patterns or markers in the event stream. For example, when a special “watermark event” is encountered.

Implementations

impl PunctuatedWatermark

pub fn new<F>(extractor: F) -> Self

where F: Fn(i64, u32) -> Option<i64> + Send + Sync + 'static,

Creates a new punctuated watermark generator

Arguments

• extractor - Function that returns Some(watermark_timestamp) if the event should trigger a watermark emission, None otherwise

pub fn every_n_events(n: u64) -> Self

Creates a watermark generator that emits on every Nth event

pub fn on_timestamp_boundary(boundary_ms: i64) -> Self

Creates a watermark generator that emits when timestamp crosses boundaries

Trait Implementations

impl WatermarkGenerator for PunctuatedWatermark

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

Called when a new event arrives

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

Called periodically to check if a watermark should be emitted

fn current_watermark(&self) -> Watermark

Gets the current watermark without advancing it

fn reset(&mut self)

Resets the watermark generator to its initial state

fn partition_watermark(&self, partition: u32) -> Option<Watermark>

Gets the watermark for a specific partition