Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.scheduler.stopwithsavepoint |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpoint |
PendingCheckpoint.finalizeCheckpoint(CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup,
Executor executor,
PendingCheckpointStats statsCallback) |
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> |
DeactivatedCheckpointCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
EmbeddedCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
CompletedCheckpointStore.getAllCheckpoints()
Returns all
CompletedCheckpoint instances. |
List<CompletedCheckpoint> |
StandaloneCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
DefaultCompletedCheckpointStore.getAllCheckpoints() |
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 |
DeactivatedCheckpointCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
EmbeddedCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
CompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Adds a
CompletedCheckpoint instance to the list of completed checkpoints. |
void |
StandaloneCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
DefaultCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Synchronously writes the new checkpoints to state handle store and asynchronously removes
older ones.
|
void |
CheckpointsCleaner.cleanCheckpointOnFailedStoring(CompletedCheckpoint completedCheckpoint,
Executor executor) |
static CompletedCheckpointStore |
CompletedCheckpointStore.storeFor(Runnable postCleanupAction,
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 |
---|
DefaultCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
StateHandleStore<CompletedCheckpoint,R> stateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil,
Executor executor)
Creates a
DefaultCompletedCheckpointStore instance. |
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
org.apache.flink.runtime.checkpoint.CheckpointPlan checkpointPlan,
Collection<OperatorID> operatorCoordinatorsToConfirm,
Collection<String> masterStateIdentifiers,
CheckpointProperties props,
CheckpointStorageLocation targetLocation,
CompletableFuture<CompletedCheckpoint> onCompletionPromise) |
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–2022 The Apache Software Foundation. All rights reserved.