Class | Description |
---|---|
Checkpoints<T> |
Maintains the pending checkpoints.
|
CheckpointsBroker |
Hand offs the
Checkpoints from the head operator to the tail operator so that the tail
operator could decrease the reference count of the raw state when checkpoints are aborted. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.