A checkpoint ID counter.
A factory for per Job checkpoint recovery components.
A bounded LIFO-queue of
Interface that allows to implement different strategies for repartitioning of operator state as parallelism changes.
Base class for checkpoint statistics.
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
This actor listens to changes in the JobStatus and activates or deactivates the periodic checkpoint scheduler.
Encapsulates all the meta data for a checkpoint.
A collection of simple metrics, around the triggering of a checkpoint.
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
Counts of checkpoints.
An array based history of checkpoint stats.
A snapshot of the checkpoint stats.
Tracker for checkpoint statistics.
A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state) and that is considered completed.
Statistics for a successfully completed checkpoint.
Summary over all completed checkpoints.
Statistics for a failed checkpoint.
Helper for keeping track of min/max/average summaries.
A pending checkpoint is a checkpoint that has been started, but has not been acknowledged by all tasks that need to acknowledge it.
Statistics for a pending checkpoint that is still in progress.
Statistics for a restored checkpoint.
Current default implementation of
This class encapsulates the operation of assigning restored state when restoring from a checkpoint.
Container for the chained state of one parallel subtask of an operator/task.
Statistics for a single subtask that is part of a checkpoint.
Simple container class which contains the task state and key-group state handles for the sub tasks of a
Statistics for a single task/operator that gathers all statistics of its subtasks and provides summary statistics about all subtasks.
Summary of the subtask stats of a single task/operator.
Various reasons why a checkpoint was declined.
Status of the tracked checkpoint.
Result of the
Base class for checkpoint related exceptions.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.