Expand description
Snapshot and recovery management for DAG checkpoints.
DagCheckpointSnapshot captures operator state at a point-in-time.
It uses std::collections::HashMap (not FxHashMap) because it must
be Serialize/Deserialize for persistence by the caller.
DagRecoveryManager holds snapshots and provides recovery APIs.
Structs§
- DagCheckpoint
Snapshot - A point-in-time snapshot of the entire DAG’s operator state.
- DagRecovery
Manager - Manages checkpoint snapshots and provides recovery.
- Recovered
DagState - Recovered DAG state from a checkpoint snapshot.
- Serializable
Operator State - Serializable form of
OperatorState.