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()
Creates the checkpoint properties for a (manually triggered) savepoint.
|
static CheckpointProperties |
CheckpointProperties.forSyncSavepoint() |
CheckpointProperties |
AbstractCheckpointStats.getProperties()
Returns the properties of this checkpoint.
|
CheckpointProperties |
RestoredCheckpointStats.getProperties()
Returns the properties of the restored checkpoint.
|
CheckpointProperties |
CompletedCheckpoint.getProperties() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(long timestamp,
CheckpointProperties props,
String externalSavepointLocation,
boolean isPeriodic,
boolean advanceToEndOfTime) |
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<String> masterStateIdentifiers,
CheckpointProperties props,
CheckpointStorageLocation targetLocation,
Executor executor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.