Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStorageLocation |
RocksDBStateBackend.resolveCheckpoint(String pointer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
abstract CompletedCheckpointStorageLocation |
CheckpointMetadataOutputStream.closeAndFinalizeCheckpoint()
Closes the stream after all metadata was written and finalizes the checkpoint location.
|
CompletedCheckpointStorageLocation |
CheckpointStorage.resolveCheckpoint(String externalPointer)
Resolves the given pointer to a checkpoint/savepoint into a checkpoint location.
|
CompletedCheckpointStorageLocation |
CheckpointStorageCoordinatorView.resolveCheckpoint(String externalPointer)
Resolves the given pointer to a checkpoint/savepoint into a checkpoint location.
|
Modifier and Type | Class and Description |
---|---|
class |
FsCompletedCheckpointStorageLocation
A
CompletedCheckpointStorageLocation that resides on a file system. |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStorageLocation |
AbstractFileStateBackend.resolveCheckpoint(String pointer)
Deprecated.
|
CompletedCheckpointStorageLocation |
AbstractFsCheckpointStorageAccess.resolveCheckpoint(String checkpointPointer) |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStorageLocation |
JobManagerCheckpointStorage.resolveCheckpoint(String pointer) |
CompletedCheckpointStorageLocation |
FileSystemCheckpointStorage.resolveCheckpoint(String pointer) |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStorageLocation |
BatchExecutionCheckpointStorage.resolveCheckpoint(String externalPointer) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.