Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
OperatorState
Simple container class which contains the raw/managed/legacy operator state and key-group state handles for the sub
tasks of an operator.
|
TaskState
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
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.
|
CheckpointOptions.CheckpointType
The type of checkpoint to perform.
|
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
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
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.
|
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/legacy operator state and key-group state handles for the sub
tasks of an operator.
|
OperatorStateRepartitioner
Interface that allows to implement different strategies for repartitioning of operator state as parallelism changes.
|
OperatorSubtaskState
Container for the state of one parallel subtask 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. |
RestoredCheckpointStats
Statistics for a restored 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.
|
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 |
---|
CompletedCheckpoint
A CompletedCheckpoint describes a checkpoint after all required tasks acknowledged it (with their state)
and that is considered successful.
|
MasterState
Simple encapsulation of state generated by checkpoint coordinator.
|
OperatorState
Simple container class which contains the raw/managed/legacy operator state and key-group state handles for the sub
tasks of an operator.
|
TaskState
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
SubtaskState
Container for the chained state of one parallel subtask of an operator/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. |
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.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
Class and Description |
---|
CheckpointCoordinatorGateway |
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.
|
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
CheckpointOptions
Options for performing the checkpoint.
|
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Class and Description |
---|
CheckpointOptions
Options for performing the checkpoint.
|
SubtaskState
Container for the chained state of one parallel subtask of an operator/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.
|
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
Class and Description |
---|
CheckpointMetrics
A collection of simple metrics, around the triggering of a checkpoint.
|
CheckpointOptions
Options for performing the checkpoint.
|
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
Class and Description |
---|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
ZooKeeperCheckpointIDCounter
CheckpointIDCounter instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Class and Description |
---|
AbstractCheckpointStats
Base class for checkpoint statistics.
|
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.
|
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.
|
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.