Expand description
DAG-native watermark tracking.
Provides Vec-indexed O(1) watermark propagation through a DAG topology. Watermarks flow from source nodes downstream using min-semantics at fan-in (merge) nodes, matching the global watermark tracking pattern but scoped to DAG nodes.
§Ring 0 Compatibility
All operations use pre-allocated Vec<T> indexed by NodeId.0 for
zero-allocation lookups, consistent with DagExecutor.
Structs§
- DagWatermark
Checkpoint - Checkpoint state for
DagWatermarkTracker. - DagWatermark
Tracker - Vec-indexed O(1) watermark tracker for DAG pipelines.