Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpoint |
PendingCheckpoint.finalizeCheckpoint() |
CompletedCheckpoint |
ZooKeeperCompletedCheckpointStore.getLatestCheckpoint() |
CompletedCheckpoint |
StandaloneCompletedCheckpointStore.getLatestCheckpoint() |
CompletedCheckpoint |
CompletedCheckpointStore.getLatestCheckpoint()
Returns the latest
CompletedCheckpoint instance or null if none was
added. |
Modifier and Type | Method and Description |
---|---|
List<CompletedCheckpoint> |
ZooKeeperCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
StandaloneCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
CompletedCheckpointStore.getAllCheckpoints()
Returns all
CompletedCheckpoint instances. |
Future<CompletedCheckpoint> |
PendingCheckpoint.getCompletionFuture()
Returns the completion future.
|
List<CompletedCheckpoint> |
CheckpointCoordinator.getSuccessfulCheckpoints() |
Future<CompletedCheckpoint> |
CheckpointCoordinator.triggerSavepoint(long timestamp,
String targetDirectory)
Triggers a savepoint with the given savepoint directory as a target.
|
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint)
Synchronously writes the new checkpoints to ZooKeeper and asynchronously removes older ones.
|
void |
StandaloneCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint) |
void |
CompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint)
Adds a
CompletedCheckpoint instance to the list of completed checkpoints. |
Constructor and Description |
---|
ZooKeeperCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
org.apache.curator.framework.CuratorFramework client,
String checkpointsPath,
RetrievableStateStorageHelper<CompletedCheckpoint> stateStorage,
Executor executor)
Creates a
ZooKeeperCompletedCheckpointStore instance. |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpoint |
SavepointLoader.loadAndValidateSavepoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
String savepointPath,
ClassLoader userClassLoader,
boolean allowNonRestoredState)
Loads a savepoint back as a
CompletedCheckpoint . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.