Struct GlobalWatermarkCollector 

pub struct GlobalWatermarkCollector { /* private fields */ }

Collects watermarks from multiple cores and computes the global watermark.

This is used by the thread-per-core runtime coordinator to aggregate watermarks across all cores.

Implementations

impl GlobalWatermarkCollector

pub fn new(num_cores: usize) -> Self

Creates a new collector for the given number of cores.

pub fn update_core( &mut self, core_id: usize, watermark: i64, ) -> Option<Watermark>

Updates the watermark for a specific core.

Returns

Some(Watermark) if the global watermark advances.

pub fn global_watermark(&self) -> Option<Watermark>

Returns the current global watermark.

pub fn core_watermark(&self, core_id: usize) -> Option<i64>

Returns the watermark for a specific core.

pub fn num_cores(&self) -> usize

Returns the number of cores.

Trait Implementations

impl Debug for GlobalWatermarkCollector

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

Formats the value using the given formatter.