Class and Description |
---|
CheckpointCoordinator
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
|
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. |
PendingCheckpoint
A pending checkpoint is a checkpoint that has been started, but has not been
acknowledged by all tasks that need to acknowledge it.
|
SavepointCoordinator
The savepoint coordinator is a slightly modified variant of the regular
checkpoint coordinator.
|
SavepointStore
Simple wrapper around the state store for savepoints.
|
StateForTask
Simple bean to describe the state belonging to a parallel operator.
|
StateStore
A simple
org.apache.flink.runtime.state.StateBackend backend object
store interface. |
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.
|
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. |
SavepointCoordinator
The savepoint coordinator is a slightly modified variant of the regular
checkpoint coordinator.
|
StateStore
A simple
org.apache.flink.runtime.state.StateBackend backend object
store interface. |
Class and Description |
---|
CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
|
SavepointStore
Simple wrapper around the state store for savepoints.
|
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.
|
SavepointStore
Simple wrapper around the state store for savepoints.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.