Interface | Description |
---|---|
CheckpointIDCounter |
A checkpoint ID counter.
|
CheckpointRecoveryFactory |
A factory for per Job checkpoint recovery components.
|
CompletedCheckpointStore |
A bounded LIFO-queue of
CompletedCheckpoint instances. |
Class | Description |
---|---|
CheckpointCoordinator |
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
CheckpointCoordinatorDeActivator |
This actor listens to changes in the JobStatus and activates or deactivates the periodic
checkpoint scheduler.
|
CompletedCheckpoint |
A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state)
and that is considered completed.
|
KeyGroupState |
Simple container class which contains the serialized state handle for a key group.
|
PendingCheckpoint |
A pending checkpoint is a checkpoint that has been started, but has not been
acknowledged by all tasks that need to acknowledge it.
|
StandaloneCheckpointIDCounter |
CheckpointIDCounter instances for JobManagers running in RecoveryMode.STANDALONE . |
StandaloneCheckpointRecoveryFactory |
CheckpointCoordinator components in RecoveryMode.STANDALONE . |
SubtaskState |
Simple bean to describe the state belonging to a parallel operator.
|
TaskState |
Simple container class which contains the task state and key-value state handles for the sub
tasks of a
JobVertex . |
ZooKeeperCheckpointIDCounter |
CheckpointIDCounter instances for JobManagers running in RecoveryMode.ZOOKEEPER . |
ZooKeeperCheckpointRecoveryFactory |
CheckpointCoordinator components in RecoveryMode.ZOOKEEPER . |
ZooKeeperCompletedCheckpointStore |
CompletedCheckpointStore for JobManagers running in RecoveryMode.ZOOKEEPER . |
Enum | Description |
---|---|
PendingCheckpoint.TaskAcknowledgeResult |
Result of the
PendingCheckpoint.acknowledgedTasks method. |
Exception | Description |
---|---|
CheckpointException |
Base class for checkpoint related exceptions.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.