Package org.apache.flink.runtime.checkpoint

Interface Summary

Interface	Description
CheckpointCoordinatorGateway
CheckpointIDCounter	A checkpoint ID counter.
CheckpointRecoveryFactory	A factory for per Job checkpoint recovery components.
CompletedCheckpointStore	A bounded LIFO-queue of CompletedCheckpoint instances.
MasterTriggerRestoreHook<T>	The interface for hooks that can be called by the checkpoint coordinator when triggering or restoring a checkpoint.
MasterTriggerRestoreHook.Factory	A factory to instantiate a MasterTriggerRestoreHook.
OperatorStateRepartitioner	Interface that allows to implement different strategies for repartitioning of operator state as parallelism changes.

Class Summary

Class	Description
AbstractCheckpointStats	Base class for checkpoint statistics.
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.
CheckpointMetaData	Encapsulates all the meta data for a checkpoint.
CheckpointMetrics	A collection of simple metrics, around the triggering of a checkpoint.
CheckpointOptions	Options for performing the checkpoint.
CheckpointProperties	The configuration of a checkpoint, such as whether The checkpoint should be persisted The checkpoint must be full, or may be incremental (not yet implemented) The checkpoint format must be the common (cross backend) format, or may be state-backend specific (not yet implemented) when the checkpoint should be garbage collected
CheckpointStatsCounts	Counts of checkpoints.
CheckpointStatsHistory	An array based history of checkpoint stats.
CheckpointStatsSnapshot	A snapshot of the checkpoint stats.
CheckpointStatsTracker	Tracker for checkpoint statistics.
CompletedCheckpoint	A CompletedCheckpoint describes a checkpoint after all required tasks acknowledged it (with their state) and that is considered successful.
CompletedCheckpointStats	Statistics for a successfully completed checkpoint.
CompletedCheckpointStatsSummary	Summary over all completed checkpoints.
FailedCheckpointStats	Statistics for a failed checkpoint.
MasterState	Simple encapsulation of state generated by checkpoint coordinator.
MinMaxAvgStats	Helper for keeping track of min/max/average summaries.
OperatorState	Simple container class which contains the raw/managed operator state and key-group state handles from all sub tasks of an operator and therefore represents the complete state of a logical operator.
OperatorSubtaskState	This class encapsulates the state for one parallel instance of an operator.
PendingCheckpoint	A pending checkpoint is a checkpoint that has been started, but has not been acknowledged by all tasks that need to acknowledge it.
PendingCheckpointStats	Statistics for a pending checkpoint that is still in progress.
RestoredCheckpointStats	Statistics for a restored checkpoint.
RoundRobinOperatorStateRepartitioner	Current default implementation of OperatorStateRepartitioner that redistributes state in round robin fashion.
StandaloneCheckpointIDCounter	CheckpointIDCounter instances for JobManagers running in HighAvailabilityMode.NONE.
StandaloneCheckpointRecoveryFactory	CheckpointCoordinator components in HighAvailabilityMode.NONE.
StandaloneCompletedCheckpointStore	CompletedCheckpointStore for JobManagers running in HighAvailabilityMode.NONE.
StateAssignmentOperation	This class encapsulates the operation of assigning restored state when restoring from a checkpoint.
SubtaskState	Container for the chained state of one parallel subtask of an operator/task.
SubtaskStateStats	Statistics for a single subtask that is part of a checkpoint.
TaskState	Deprecated Internal class for savepoint backwards compatibility.
TaskStateSnapshot	This class encapsulates state handles to the snapshots of all operator instances executed within one task.
TaskStateStats	Statistics for a single task/operator that gathers all statistics of its subtasks and provides summary statistics about all subtasks.
TaskStateStats.TaskStateStatsSummary	Summary of the subtask stats of a single task/operator.
ZooKeeperCheckpointIDCounter	CheckpointIDCounter instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER.
ZooKeeperCheckpointRecoveryFactory	CheckpointCoordinator components in HighAvailabilityMode.ZOOKEEPER.
ZooKeeperCompletedCheckpointStore	CompletedCheckpointStore for JobManagers running in HighAvailabilityMode.ZOOKEEPER.

Enum Summary

Enum	Description
CheckpointDeclineReason	Various reasons why a checkpoint was declined.
CheckpointOptions.CheckpointType	The type of checkpoint to perform.
CheckpointStatsStatus	Status of the tracked checkpoint.
PendingCheckpoint.TaskAcknowledgeResult	Result of the PendingCheckpoint.acknowledgedTasks method.

Exception Summary

Exception	Description
CheckpointException	Base class for checkpoint related exceptions.