Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.scheduler.stopwithsavepoint | |
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpoint |
StandaloneCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
CompletedCheckpoint |
CompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Adds a
CompletedCheckpoint instance to the list of completed checkpoints. |
CompletedCheckpoint |
EmbeddedCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
CompletedCheckpoint |
DefaultCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Synchronously writes the new checkpoints to state handle store and asynchronously removes
older ones.
|
CompletedCheckpoint |
DeactivatedCheckpointCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
CompletedCheckpoint |
PendingCheckpoint.finalizeCheckpoint(CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup,
Executor executor) |
default CompletedCheckpoint |
CompletedCheckpointStore.getLatestCheckpoint()
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,
CheckpointProperties checkpointProperties,
RestoreMode restoreMode) |
Modifier and Type | Method and Description |
---|---|
List<CompletedCheckpoint> |
StandaloneCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
CompletedCheckpointStore.getAllCheckpoints()
Returns all
CompletedCheckpoint instances. |
List<CompletedCheckpoint> |
EmbeddedCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
DefaultCompletedCheckpointStore.getAllCheckpoints() |
List<CompletedCheckpoint> |
DeactivatedCheckpointCompletedCheckpointStore.getAllCheckpoints() |
CompletableFuture<CompletedCheckpoint> |
PendingCheckpoint.getCompletionFuture()
Returns the completion future.
|
List<CompletedCheckpoint> |
CheckpointCoordinator.getSuccessfulCheckpoints() |
static <R extends ResourceVersion<R>> |
DefaultCompletedCheckpointStoreUtils.retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil)
Fetch all
completed checkpoints from an external store . |
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,
SavepointFormatType formatType)
Triggers a savepoint with the given savepoint directory as a target.
|
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerSynchronousSavepoint(boolean terminate,
String targetLocation,
SavepointFormatType formatType)
Triggers a synchronous savepoint with the given savepoint directory as a target.
|
Modifier and Type | Method and Description |
---|---|
CompletedCheckpoint |
StandaloneCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
CompletedCheckpoint |
CompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Adds a
CompletedCheckpoint instance to the list of completed checkpoints. |
CompletedCheckpoint |
EmbeddedCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
CompletedCheckpoint |
DefaultCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Synchronously writes the new checkpoints to state handle store and asynchronously removes
older ones.
|
CompletedCheckpoint |
DeactivatedCheckpointCompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
CheckpointsCleaner.cleanCheckpointOnFailedStoring(CompletedCheckpoint completedCheckpoint,
Executor executor) |
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) |
static <R extends ResourceVersion<R>> |
DefaultCompletedCheckpointStoreUtils.retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil)
Fetch all
completed checkpoints from an external store . |
protected void |
AbstractCompleteCheckpointStore.unregisterUnusedState(Deque<CompletedCheckpoint> unSubsumedCheckpoints)
Unregister shared states that are no longer in use.
|
Constructor and Description |
---|
DefaultCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
StateHandleStore<CompletedCheckpoint,R> stateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil,
Collection<CompletedCheckpoint> completedCheckpoints,
SharedStateRegistry sharedStateRegistry,
Executor executor)
Creates a
DefaultCompletedCheckpointStore instance. |
DefaultCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
StateHandleStore<CompletedCheckpoint,R> stateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil,
Collection<CompletedCheckpoint> completedCheckpoints,
SharedStateRegistry sharedStateRegistry,
Executor executor)
Creates a
DefaultCompletedCheckpointStore instance. |
EmbeddedCompletedCheckpointStore(int maxRetainedCheckpoints,
Collection<CompletedCheckpoint> initialCheckpoints,
RestoreMode restoreMode) |
EmbeddedCompletedCheckpointStore(int maxRetainedCheckpoints,
Collection<CompletedCheckpoint> initialCheckpoints,
SharedStateRegistry sharedStateRegistry) |
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
CheckpointPlan checkpointPlan,
Collection<OperatorID> operatorCoordinatorsToConfirm,
Collection<String> masterStateIdentifiers,
CheckpointProperties props,
CompletableFuture<CompletedCheckpoint> onCompletionPromise,
PendingCheckpointStats pendingCheckpointStats) |
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 . |
Modifier and Type | Method and Description |
---|---|
void |
SharedStateRegistry.registerAllAfterRestored(CompletedCheckpoint checkpoint,
RestoreMode mode)
Set the lowest checkpoint ID below which no state is discarded, inclusive.
|
void |
SharedStateRegistryImpl.registerAllAfterRestored(CompletedCheckpoint checkpoint,
RestoreMode mode) |
Modifier and Type | Method and Description |
---|---|
SharedStateRegistry |
SharedStateRegistryFactory.create(Executor deleteExecutor,
Collection<CompletedCheckpoint> checkpoints,
RestoreMode restoreMode)
Factory method for
SharedStateRegistry . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.