Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCheckpointPlan
The default implementation of he
CheckpointPlan . |
Modifier and Type | Method and Description |
---|---|
CheckpointPlan |
PendingCheckpoint.getCheckpointPlan() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CheckpointPlan> |
DefaultCheckpointPlanCalculator.calculateCheckpointPlan() |
CompletableFuture<CheckpointPlan> |
CheckpointPlanCalculator.calculateCheckpointPlan()
Calculates the plan of the next checkpoint.
|
Constructor and Description |
---|
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
CheckpointPlan checkpointPlan,
Collection<OperatorID> operatorCoordinatorsToConfirm,
Collection<String> masterStateIdentifiers,
CheckpointProperties props,
CompletableFuture<CompletedCheckpoint> onCompletionPromise,
PendingCheckpointStats pendingCheckpointStats,
CompletableFuture<Void> masterTriggerCompletionPromise) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.