Expand description
Chandy–Lamport barrier alignment. One BarrierTracker per sharded
operator; observe(input, barrier) returns Some once every input
has seen the same checkpoint id.
Structs§
- Barrier
Tracker - Per-operator alignment state. Cheap to construct; one instance per sharded operator.