Package | Description |
---|---|
org.apache.flink.iteration.checkpoint |
Class and Description |
---|
Checkpoints
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.