Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
FailedCheckpointStats
Statistics for a failed checkpoint.
|
Modifier and Type | Method and Description |
---|---|
PendingCheckpointStats |
CheckpointStatsTracker.getPendingCheckpointStats(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
void |
PendingCheckpoint.abort(CheckpointFailureReason reason,
Throwable cause,
CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup,
Executor executor,
PendingCheckpointStats statsCallback)
Aborts a checkpoint with reason and cause.
|
PendingCheckpoint.TaskAcknowledgeResult |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID executionAttemptId,
TaskStateSnapshot operatorSubtaskStates,
CheckpointMetrics metrics,
PendingCheckpointStats statsCallback)
Acknowledges the task with the given execution attempt id and the given subtask state.
|
CompletedCheckpoint |
PendingCheckpoint.finalizeCheckpoint(CheckpointsCleaner checkpointsCleaner,
Runnable postCleanup,
Executor executor,
PendingCheckpointStats statsCallback) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.