Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
SnapshotType
The type of checkpoint to perform.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointIDCounter
A checkpoint ID counter.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CheckpointStoreUtil
CompletedCheckpointStore utility interfaces. |
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
Class and Description |
---|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
Class and Description |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
AbstractCompleteCheckpointStore
The abstract class of
CompletedCheckpointStore , which holds the SharedStateRegistry and provides the registration of shared state. |
Checkpoint
A checkpoint, pending or completed.
|
Checkpoint.DiscardObject
Extra interface for discarding the checkpoint.
|
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.
|
CheckpointMetricsBuilder
A builder for
CheckpointMetrics . |
CheckpointOptions
Options for performing the checkpoint.
|
CheckpointOptions.AlignmentType
How a checkpoint should be aligned.
|
CheckpointPlan
The plan of one checkpoint, indicating which tasks to trigger, waiting for acknowledge or commit
for one specific checkpoint.
|
CheckpointPlanCalculator
Calculates the plan of the next checkpoint, including the tasks to trigger, wait or commit for
each checkpoint.
|
CheckpointPlanCalculatorContext
Provides the context for
DefaultCheckpointPlanCalculator to compute the plan of
checkpoints. |
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.
|
CheckpointsCleaner
Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to
clean.
|
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.
|
CheckpointStoreUtil
CompletedCheckpointStore utility interfaces. |
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.
|
CompletedCheckpointStatsSummarySnapshot
Immutable snapshot of
CompletedCheckpointStatsSummary . |
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
DeactivatedCheckpointCompletedCheckpointStore
This class represents a
CompletedCheckpointStore if checkpointing has been disabled. |
DeactivatedCheckpointIDCounter
This class represents a
CheckpointIDCounter if checkpointing is deactivated. |
ExecutionAttemptMappingProvider
Provides a mapping from
ExecutionAttemptID to ExecutionVertex for currently
running execution attempts. |
FailedCheckpointStats
Statistics for a failed checkpoint.
|
FinishedOperatorSubtaskState
A specialized
OperatorSubtaskState representing the subtask is finished. |
FinishedTaskStateProvider
Collects and fulfills the finished state for the subtasks or operators.
|
FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException
Thrown when some subtasks of the operator have been finished but state doesn't support that
(e.g.
|
InflightDataRescalingDescriptor
Captures ambiguous mappings of old channels to new channels for a particular gate or partition.
|
InflightDataRescalingDescriptor.InflightDataGateOrPartitionRescalingDescriptor
Captures ambiguous mappings of old channels to new channels.
|
InflightDataRescalingDescriptor.InflightDataGateOrPartitionRescalingDescriptor.MappingType
Type of mapping which should be used for this in-flight data.
|
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.
|
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.
|
OperatorSubtaskState.Builder
The builder for a new
OperatorSubtaskState which can be obtained by OperatorSubtaskState.builder() . |
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. |
PendingCheckpointStats
Statistics for a pending checkpoint that is still in progress.
|
PerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper
Restores or creates a
CompletedCheckpointStore , optionally using an existing one. |
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. |
RescaleMappings
Contains the fine-grain channel mappings that occur when a connected operator has been rescaled.
|
RestoredCheckpointStats
Statistics for a restored checkpoint.
|
SavepointType
The type of checkpoint to perform.
|
SavepointType.PostCheckpointAction
What's the intended action after the checkpoint (relevant for stopping with savepoint).
|
SnapshotType
The type of checkpoint to perform.
|
SnapshotType.SharingFilesStrategy
Defines what files can be shared across snapshots.
|
StateObjectCollection
This class represents a generic collection for
StateObject s. |
StatsSummary
Aggregated values of some measurement such as min/max/average state size.
|
StatsSummarySnapshot
Immutable snapshot of
StatsSummary . |
SubtaskState
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
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.
|
VertexFinishedStateChecker
This class encapsulates the operation that checks if there are illegal modification to the
JobGraph when restoring from a checkpoint with partially or fully finished operator states.
|
ZooKeeperCheckpointStoreUtil
Singleton
CheckpointStoreUtil implementation for ZooKeeper. |
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 |
---|
CheckpointProperties
The configuration of a checkpoint.
|
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 |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
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.
|
CheckpointPlanCalculatorContext
Provides the context for
DefaultCheckpointPlanCalculator to compute the plan of
checkpoints. |
CheckpointsCleaner
Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to
clean.
|
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 |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
RescaleMappings
Contains the fine-grain channel mappings that occur when a connected operator has been rescaled.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
CheckpointMetaData
Encapsulates all the meta data for a checkpoint.
|
CheckpointMetricsBuilder
A builder for
CheckpointMetrics . |
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.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CompletedCheckpoint
A CompletedCheckpoint describes a checkpoint after all required tasks acknowledged it (with their
state) and that is considered successful.
|
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.
|
StatsSummary
Aggregated values of some measurement such as min/max/average state size.
|
StatsSummarySnapshot
Immutable snapshot of
StatsSummary . |
Class and Description |
---|
CheckpointIDCounter
A checkpoint ID counter.
|
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. |
CheckpointsCleaner
Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to
clean.
|
CompletedCheckpoint
A CompletedCheckpoint describes a checkpoint after all required tasks acknowledged it (with their
state) and that is considered successful.
|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
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.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CheckpointScheduling
CheckpointScheduling provides methods for starting and stopping the periodic scheduling
of checkpoints. |
CheckpointsCleaner
Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to
clean.
|
CompletedCheckpoint
A CompletedCheckpoint describes a checkpoint after all required tasks acknowledged it (with their
state) and that is considered successful.
|
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CheckpointScheduling
CheckpointScheduling provides methods for starting and stopping the periodic scheduling
of checkpoints. |
CheckpointsCleaner
Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to
clean.
|
Class and Description |
---|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
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.
|
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.
|
InflightDataRescalingDescriptor
Captures ambiguous mappings of old channels to new channels for a particular gate or partition.
|
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. |
SnapshotType
The type of checkpoint to perform.
|
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.
|
CheckpointException
Base class for checkpoint related exceptions.
|
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 |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
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 |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
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 |
---|
CheckpointOptions
Options for performing the checkpoint.
|
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 |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
InflightDataRescalingDescriptor
Captures ambiguous mappings of old channels to new channels for a particular gate or partition.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
InflightDataRescalingDescriptor
Captures ambiguous mappings of old channels to new channels for a particular gate or partition.
|
Class and Description |
---|
CheckpointException
Base class for checkpoint related exceptions.
|
CheckpointMetaData
Encapsulates all the meta data for a checkpoint.
|
CheckpointMetricsBuilder
A builder for
CheckpointMetrics . |
CheckpointOptions
Options for performing the checkpoint.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.