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.
|
CheckpointDeclineReason
Various reasons why a checkpoint was declined.
|
CheckpointException
Base class for checkpoint related exceptions.
|
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.
|
CheckpointTriggerResult
The result of triggering a checkpoint.
|
CheckpointType
The type of checkpoint to perform.
|
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.
|
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.
|
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 |
---|
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.
|
TaskState
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
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.
|
CheckpointRetentionPolicy
Policy for whether checkpoints are retained after a job terminates.
|
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 |
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 |
---|
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 |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
Class and Description |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
CheckpointStatsStatus
Status of the tracked 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.
|
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 |
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 |
---|
MasterTriggerRestoreHook
The interface for hooks that can be called by the checkpoint coordinator when triggering or
restoring a checkpoint.
|
Class and Description |
---|
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 |
---|
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.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.