Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Method and Description |
---|---|
static CheckpointProperties |
CheckpointProperties.forCheckpoint(CheckpointRetentionPolicy policy)
Creates the checkpoint properties for a checkpoint.
|
static CheckpointProperties |
CheckpointProperties.forSavepoint(boolean forced)
Creates the checkpoint properties for a (manually triggered) savepoint.
|
static CheckpointProperties |
CheckpointProperties.forSyncSavepoint(boolean forced,
boolean terminate) |
CheckpointProperties |
AbstractCheckpointStats.getProperties()
Returns the properties of this checkpoint.
|
CheckpointProperties |
CompletedCheckpoint.getProperties() |
CheckpointProperties |
RestoredCheckpointStats.getProperties()
Returns the properties of the restored checkpoint.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(CheckpointProperties props,
String externalSavepointLocation,
boolean isPeriodic) |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation) |
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm,
Collection<OperatorID> operatorCoordinatorsToConfirm,
Collection<String> masterStateIdentifiers,
CheckpointProperties props,
CheckpointStorageLocation targetLocation,
Executor executor,
CompletableFuture<CompletedCheckpoint> onCompletionPromise) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.