Modifier and Type | Method and Description |
---|---|
CheckpointStorageLocationReference |
CheckpointOptions.getTargetLocation()
Returns the target location for the checkpoint.
|
Constructor and Description |
---|
CheckpointOptions(CheckpointType checkpointType,
CheckpointStorageLocationReference targetLocation) |
Modifier and Type | Method and Description |
---|---|
static CheckpointStorageLocationReference |
CheckpointStorageLocationReference.getDefault() |
CheckpointStorageLocationReference |
CheckpointStorageLocation.getLocationReference()
Gets a reference to the storage location.
|
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
CheckpointStorageWorkerView.resolveCheckpointStorageLocation(long checkpointId,
CheckpointStorageLocationReference reference)
Resolves a storage location reference into a CheckpointStreamFactory.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointStorageLocationReference |
AbstractFsCheckpointStorage.encodePathAsReference(Path path)
Encodes the given path as a reference in bytes.
|
CheckpointStorageLocationReference |
FsCheckpointStorageLocation.getLocationReference() |
Modifier and Type | Method and Description |
---|---|
static Path |
AbstractFsCheckpointStorage.decodePathFromReference(CheckpointStorageLocationReference reference)
Decodes the given reference into a path.
|
CheckpointStreamFactory |
FsCheckpointStorage.resolveCheckpointStorageLocation(long checkpointId,
CheckpointStorageLocationReference reference) |
Constructor and Description |
---|
FsCheckpointStorageLocation(FileSystem fileSystem,
Path checkpointDir,
Path sharedStateDir,
Path taskOwnedStateDir,
CheckpointStorageLocationReference reference,
int fileStateSizeThreshold,
int writeBufferSize) |
Modifier and Type | Method and Description |
---|---|
CheckpointStorageLocationReference |
NonPersistentMetadataCheckpointStorageLocation.getLocationReference() |
CheckpointStorageLocationReference |
PersistentMetadataCheckpointStorageLocation.getLocationReference() |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
MemoryBackendCheckpointStorage.resolveCheckpointStorageLocation(long checkpointId,
CheckpointStorageLocationReference reference) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.