Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory |
Modifier and Type | Method and Description |
---|---|
CheckpointStorageLocation |
PendingCheckpoint.getCheckpointStorageLocation() |
Modifier and Type | Method and Description |
---|---|
void |
PendingCheckpoint.setCheckpointTargetLocation(CheckpointStorageLocation targetLocation) |
Modifier and Type | Method and Description |
---|---|
CheckpointStorageLocation |
CheckpointStorageCoordinatorView.initializeLocationForCheckpoint(long checkpointId)
Initializes a storage location for new checkpoint with the given ID.
|
CheckpointStorageLocation |
CheckpointStorageCoordinatorView.initializeLocationForSavepoint(long checkpointId,
String externalLocationPointer)
Initializes a storage location for new savepoint with the given ID.
|
Modifier and Type | Class and Description |
---|---|
class |
FsCheckpointStorageLocation
A storage location for checkpoints on a file system.
|
Modifier and Type | Method and Description |
---|---|
protected CheckpointStorageLocation |
FsCheckpointStorageAccess.createSavepointLocation(FileSystem fs,
Path location) |
protected abstract CheckpointStorageLocation |
AbstractFsCheckpointStorageAccess.createSavepointLocation(FileSystem fs,
Path location) |
CheckpointStorageLocation |
FsCheckpointStorageAccess.initializeLocationForCheckpoint(long checkpointId) |
CheckpointStorageLocation |
AbstractFsCheckpointStorageAccess.initializeLocationForSavepoint(long checkpointId,
String externalLocationPointer)
Creates a file system based storage location for a savepoint.
|
Modifier and Type | Class and Description |
---|---|
class |
NonPersistentMetadataCheckpointStorageLocation
A checkpoint storage location for the
MemoryStateBackend in case no durable persistence
for metadata has been configured. |
class |
PersistentMetadataCheckpointStorageLocation
A checkpoint storage location for the
MemoryStateBackend when it durably persists the
metadata in a file system. |
Modifier and Type | Method and Description |
---|---|
protected CheckpointStorageLocation |
MemoryBackendCheckpointStorageAccess.createSavepointLocation(FileSystem fs,
Path location) |
CheckpointStorageLocation |
MemoryBackendCheckpointStorageAccess.initializeLocationForCheckpoint(long checkpointId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.