Modifier and Type | Method and Description |
---|---|
CheckpointStorageLocationReference |
CheckpointOptions.getTargetLocation()
Returns the target location for the checkpoint.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointOptions |
CheckpointOptions.alignedNoTimeout(CheckpointType type,
CheckpointStorageLocationReference location) |
static CheckpointOptions |
CheckpointOptions.alignedWithTimeout(CheckpointStorageLocationReference location,
long alignedCheckpointTimeout) |
static CheckpointOptions |
CheckpointOptions.forConfig(CheckpointType checkpointType,
CheckpointStorageLocationReference locationReference,
boolean isExactlyOnceMode,
boolean isUnalignedEnabled,
long alignedCheckpointTimeout) |
static CheckpointOptions |
CheckpointOptions.notExactlyOnce(CheckpointType type,
CheckpointStorageLocationReference location) |
static CheckpointOptions |
CheckpointOptions.unaligned(CheckpointStorageLocationReference location) |
Constructor and Description |
---|
CheckpointOptions(CheckpointType checkpointType,
CheckpointStorageLocationReference targetLocation) |
CheckpointOptions(CheckpointType checkpointType,
CheckpointStorageLocationReference targetLocation,
CheckpointOptions.AlignmentType alignmentType,
long alignedCheckpointTimeout) |
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 |
AbstractFsCheckpointStorageAccess.encodePathAsReference(Path path)
Encodes the given path as a reference in bytes.
|
CheckpointStorageLocationReference |
FsCheckpointStorageLocation.getLocationReference() |
Modifier and Type | Method and Description |
---|---|
static Path |
AbstractFsCheckpointStorageAccess.decodePathFromReference(CheckpointStorageLocationReference reference)
Decodes the given reference into a path.
|
CheckpointStreamFactory |
FsCheckpointStorageAccess.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 |
MemoryBackendCheckpointStorageAccess.resolveCheckpointStorageLocation(long checkpointId,
CheckpointStorageLocationReference reference) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.