Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.scheduler.stopwithsavepoint |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpoint |
PendingCheckpoint.finalizeCheckpoint() |
default CompletedCheckpoint |
CompletedCheckpointStore.getLatestCheckpoint(boolean isPreferCheckpointForRecovery)
Returns the latest
CompletedCheckpoint instance or null if none was
added. |
static CompletedCheckpoint |
Checkpoints.loadAndValidateCheckpoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
CompletedCheckpointStorageLocation location,
ClassLoader classLoader,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
List<CompletedCheckpoint> |
ZooKeeperCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
StandaloneCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
CompletedCheckpointStore.getAllCheckpoints()
Returns all
CompletedCheckpoint instances. |
CompletableFuture<CompletedCheckpoint> |
PendingCheckpoint.getCompletionFuture()
Returns the completion future.
|
List<CompletedCheckpoint> |
CheckpointCoordinator.getSuccessfulCheckpoints() |
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(boolean isPeriodic)
Triggers a new standard checkpoint and uses the given timestamp as the checkpoint timestamp.
|
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(CheckpointProperties props,
String externalSavepointLocation,
boolean isPeriodic) |
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerSavepoint(String targetLocation)
Triggers a savepoint with the given savepoint directory as a target.
|
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerSynchronousSavepoint(boolean terminate,
String targetLocation)
Triggers a synchronous 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. |
static CompletedCheckpointStore |
CompletedCheckpointStore.storeFor(CompletedCheckpoint... checkpoints) |
Modifier and Type | Method and Description |
---|---|
static boolean |
CompletedCheckpoint.checkpointsMatch(Collection<CompletedCheckpoint> first,
Collection<CompletedCheckpoint> second) |
static boolean |
CompletedCheckpoint.checkpointsMatch(Collection<CompletedCheckpoint> first,
Collection<CompletedCheckpoint> second) |
Constructor and Description |
---|
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm,
Collection<OperatorID> operatorCoordinatorsToConfirm,
Collection<String> masterStateIdentifiers,
CheckpointProperties props,
CheckpointStorageLocation targetLocation,
Executor executor,
CompletableFuture<CompletedCheckpoint> onCompletionPromise) |
ZooKeeperCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
ZooKeeperStateHandleStore<CompletedCheckpoint> checkpointsInZooKeeper,
Executor executor)
Creates a
ZooKeeperCompletedCheckpointStore instance. |
Modifier and Type | Method and Description |
---|---|
void |
StopWithSavepointTerminationHandlerImpl.handleSavepointCreation(CompletedCheckpoint completedSavepoint,
Throwable throwable) |
void |
StopWithSavepointTerminationHandler.handleSavepointCreation(CompletedCheckpoint completedSavepoint,
Throwable throwable)
Handles the result of a
CompletableFuture holding a CompletedCheckpoint . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<String> |
StopWithSavepointTerminationManager.stopWithSavepoint(CompletableFuture<CompletedCheckpoint> completedSavepointFuture,
CompletableFuture<Collection<ExecutionState>> terminatedExecutionStatesFuture,
ComponentMainThreadExecutor mainThreadExecutor)
Enforces the correct completion order of the passed
CompletableFuture instances in
accordance to the contract of StopWithSavepointTerminationHandler . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.