Skip to main content

check_watermark_gate

laminar_core::aggregation::gossip_aggregates

Function check_watermark_gate 

Source 
pub fn check_watermark_gate(
    window_end: i64,
    node_watermarks: &FxHashMap<NodeId, i64>,
) -> WatermarkGateStatus
Expand description

Checks watermark convergence for window completion.