Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Method and Description |
---|---|
void |
PendingCheckpoint.abort(CheckpointFailureReason reason,
Throwable cause,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup,
Executor executor)
Aborts a checkpoint with reason and cause.
|
void |
DefaultCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Synchronously writes the new checkpoints to state handle store and asynchronously removes
older ones.
|
void |
EmbeddedCompletedCheckpointStore.addCheckpoint(CompletedCheckpoint checkpoint,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
StandaloneCompletedCheckpointStore.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. |
CompletedCheckpoint |
PendingCheckpoint.finalizeCheckpoint(CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup,
Executor executor) |
void |
DefaultCompletedCheckpointStore.shutdown(JobStatus jobStatus,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
EmbeddedCompletedCheckpointStore.shutdown(JobStatus jobStatus,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
StandaloneCompletedCheckpointStore.shutdown(JobStatus jobStatus,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup) |
void |
CompletedCheckpointStore.shutdown(JobStatus jobStatus,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup)
Shuts down the store.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.