Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
CheckpointException
Base class for checkpoint related exceptions.
|
CheckpointFailureManager
The checkpoint failure manager which centralized manage checkpoint failure processing logic.
|
CheckpointFailureManager.FailJobCallback
A callback interface about how to fail a job.
|
CheckpointFailureReason
Various reasons why a checkpoint was failure.
|
CheckpointIDCounter
A checkpoint ID counter.
|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
CheckpointOptions
Options for performing the checkpoint.
|
CheckpointProperties
The configuration of a checkpoint.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CheckpointRetentionPolicy
Policy for whether checkpoints are retained after a job terminates.
|
CheckpointStatsCounts
Counts of checkpoints.
|
CheckpointStatsHistory
An array based history of checkpoint stats.
|
CheckpointStatsSnapshot
A snapshot of the checkpoint stats.
|
CheckpointStatsStatus
Status of the tracked checkpoint.
|
CheckpointStatsTracker
Tracker for checkpoint statistics.
|
CheckpointType
The type of checkpoint to perform.
|
CheckpointType.PostCheckpointAction
What's the intended action after the checkpoint (relevant for stopping with savepoint).
|
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.
|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
FailedCheckpointStats
Statistics for a failed checkpoint.
|
LastStateConnectionStateListener
ConnectionStateListener which records the last state it was notified about. |
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
MasterTriggerRestoreHook
The interface for hooks that can be called by the checkpoint coordinator when triggering or
restoring a checkpoint.
|
MinMaxAvgStats
Helper for keeping track of min/max/average summaries.
|
OperatorCoordinatorCheckpointContext
This context is the interface through which the
CheckpointCoordinator interacts with an
OperatorCoordinator during checkpointing and checkpoint restoring. |
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.
|
OperatorStateRepartitioner
Interface that allows to implement different strategies for repartitioning of operator state as
parallelism changes.
|
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.
|
PendingCheckpoint.TaskAcknowledgeResult
Result of the
PendingCheckpoint.acknowledgedTasks method. |
PrioritizedOperatorSubtaskState
This class is a wrapper over multiple alternative
OperatorSubtaskState that are (partial)
substitutes for each other and imposes a priority ordering over all alternatives for the
different states which define an order in which the operator should attempt to restore the state
from them. |
RestoredCheckpointStats
Statistics for a restored checkpoint.
|
StateObjectCollection
This class represents a generic collection for
StateObject s. |
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.
|
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.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
MasterTriggerRestoreHook
The interface for hooks that can be called by the checkpoint coordinator when triggering or
restoring a checkpoint.
|
Class and Description |
---|
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
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.
|
StateObjectCollection
This class represents a generic collection for
StateObject s. |
Class and Description |
---|
JobManagerTaskRestore
This class encapsulates the data from the job manager to restore a task.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
CheckpointIDCounter
A checkpoint ID counter.
|
CheckpointOptions
Options for performing the checkpoint.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CheckpointStatsSnapshot
A snapshot of the checkpoint stats.
|
CheckpointStatsTracker
Tracker for checkpoint statistics.
|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
JobManagerTaskRestore
This class encapsulates the data from the job manager to restore a task.
|
MasterTriggerRestoreHook
The interface for hooks that can be called by the checkpoint coordinator when triggering or
restoring a checkpoint.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
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.
|
CheckpointRetentionPolicy
Policy for whether checkpoints are retained after a job terminates.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointCoordinatorGateway
RPC Gateway interface for messages to the CheckpointCoordinator.
|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
CheckpointOptions
Options for performing the checkpoint.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
CheckpointFailureReason
Various reasons why a checkpoint was failure.
|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
OperatorCoordinatorCheckpointContext
This context is the interface through which the
CheckpointCoordinator interacts with an
OperatorCoordinator during checkpointing and checkpoint restoring. |
Class and Description |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
Class and Description |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
CheckpointStatsStatus
Status of the tracked checkpoint.
|
MinMaxAvgStats
Helper for keeping track of min/max/average summaries.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CheckpointScheduling
CheckpointScheduling provides methods for starting and stopping the periodic scheduling
of checkpoints. |
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CompletedCheckpoint
A CompletedCheckpoint describes a checkpoint after all required tasks acknowledged it (with their
state) and that is considered successful.
|
Class and Description |
---|
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.
|
JobManagerTaskRestore
This class encapsulates the data from the job manager to restore a task.
|
PrioritizedOperatorSubtaskState
This class is a wrapper over multiple alternative
OperatorSubtaskState that are (partial)
substitutes for each other and imposes a priority ordering over all alternatives for the
different states which define an order in which the operator should attempt to restore the state
from them. |
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointCoordinatorGateway
RPC Gateway interface for messages to the CheckpointCoordinator.
|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
CheckpointOptions
Options for performing the checkpoint.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
ZooKeeperCheckpointIDCounter
CheckpointIDCounter instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Class and Description |
---|
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.
|
Class and Description |
---|
PrioritizedOperatorSubtaskState
This class is a wrapper over multiple alternative
OperatorSubtaskState that are (partial)
substitutes for each other and imposes a priority ordering over all alternatives for the
different states which define an order in which the operator should attempt to restore the state
from them. |
StateObjectCollection
This class represents a generic collection for
StateObject s. |
Class and Description |
---|
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
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.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
PrioritizedOperatorSubtaskState
This class is a wrapper over multiple alternative
OperatorSubtaskState that are (partial)
substitutes for each other and imposes a priority ordering over all alternatives for the
different states which define an order in which the operator should attempt to restore the state
from them. |
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
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.
|
Class and Description |
---|
MasterTriggerRestoreHook
The interface for hooks that can be called by the checkpoint coordinator when triggering or
restoring a checkpoint.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
CheckpointOptions
Options for performing the checkpoint.
|
OperatorSubtaskState
This class encapsulates the state for one parallel instance of an operator.
|
PrioritizedOperatorSubtaskState
This class is a wrapper over multiple alternative
OperatorSubtaskState that are (partial)
substitutes for each other and imposes a priority ordering over all alternatives for the
different states which define an order in which the operator should attempt to restore the state
from them. |
StateObjectCollection
This class represents a generic collection for
StateObject s. |
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
Class and Description |
---|
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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.