Class and Description |
---|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
CheckpointException
Base class for checkpoint related exceptions.
|
CheckpointIDCounter
A checkpoint ID counter.
|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
CompletedCheckpoint
A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state)
and that is considered completed.
|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
KeyGroupState
Simple container class which contains the serialized state handle for a key group.
|
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. |
SubtaskState
Simple bean to describe the state belonging to a parallel operator.
|
TaskState
Simple container class which contains the task state and key-value state handles for the sub
tasks of a
JobVertex . |
Class and Description |
---|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
CheckpointIDCounter
A checkpoint ID counter.
|
CompletedCheckpoint
A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state)
and that is considered completed.
|
TaskState
Simple container class which contains the task state and key-value state handles for the sub
tasks of a
JobVertex . |
Class and Description |
---|
CompletedCheckpoint
A successful checkpoint describes a checkpoint after all required tasks acknowledged it (with their state)
and that is considered completed.
|
Class and Description |
---|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
CheckpointIDCounter
A checkpoint ID counter.
|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
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 |
---|
CompletedCheckpointStore
A bounded LIFO-queue of
CompletedCheckpoint instances. |
ZooKeeperCheckpointIDCounter
CheckpointIDCounter instances for JobManagers running in RecoveryMode.ZOOKEEPER . |
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.