Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.metadata |
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,
SavepointFormatType formatType)
Creates the checkpoint properties for a (manually triggered) savepoint.
|
static CheckpointProperties |
CheckpointProperties.forSyncSavepoint(boolean forced,
boolean terminate,
SavepointFormatType formatType) |
static CheckpointProperties |
CheckpointProperties.forUnclaimedSnapshot()
Creates the checkpoint properties for a snapshot restored in
RestoreMode.NO_CLAIM . |
CheckpointProperties |
RestoredCheckpointStats.getProperties()
Returns the properties of the restored checkpoint.
|
CheckpointProperties |
CompletedCheckpoint.getProperties() |
CheckpointProperties |
AbstractCheckpointStats.getProperties()
Returns the properties of this checkpoint.
|
Modifier and Type | Method and Description |
---|---|
Optional<CheckpointProperties> |
CompletedCheckpoint.getRestoredProperties() |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointFailureManager.handleCheckpointException(PendingCheckpoint pendingCheckpoint,
CheckpointProperties checkpointProperties,
CheckpointException exception,
ExecutionAttemptID executionAttemptID,
JobID job,
PendingCheckpointStats pendingCheckpointStats,
CheckpointStatsTracker statsTracker)
Failures on JM:
all checkpoints - go against failure counter.
|
static CompletedCheckpoint |
Checkpoints.loadAndValidateCheckpoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
CompletedCheckpointStorageLocation location,
ClassLoader classLoader,
boolean allowNonRestoredState,
CheckpointProperties checkpointProperties) |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation,
CompletedCheckpointStats completedCheckpointStats) |
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation,
CompletedCheckpointStats completedCheckpointStats,
CheckpointProperties restoredProps) |
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) |
Modifier and Type | Method and Description |
---|---|
CheckpointProperties |
CheckpointMetadata.getCheckpointProperties() |
Modifier and Type | Method and Description |
---|---|
CheckpointMetadata |
CheckpointMetadata.withProperties(CheckpointProperties properties) |
Constructor and Description |
---|
CheckpointMetadata(long checkpointId,
Collection<OperatorState> operatorStates,
Collection<MasterState> masterStates,
CheckpointProperties properties) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.