public class NonPersistentMetadataCheckpointStorageLocation extends MemCheckpointStreamFactory implements CheckpointStorageLocation
MemoryStateBackend
in case no durable persistence
for metadata has been configured.MemCheckpointStreamFactory.MemoryCheckpointOutputStream
Modifier and Type | Field and Description |
---|---|
static String |
EXTERNAL_POINTER
The external pointer returned for checkpoints that are not externally addressable.
|
Constructor and Description |
---|
NonPersistentMetadataCheckpointStorageLocation(int maxStateSize) |
Modifier and Type | Method and Description |
---|---|
CheckpointMetadataOutputStream |
createMetadataOutputStream()
Creates the output stream to persist the checkpoint metadata to.
|
void |
disposeOnFailure()
Disposes the checkpoint location in case the checkpoint has failed.
|
CheckpointStorageLocationReference |
getLocationReference()
Gets a reference to the storage location.
|
canFastDuplicate, createCheckpointStateOutputStream, duplicate, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
canFastDuplicate, createCheckpointStateOutputStream, duplicate
public static final String EXTERNAL_POINTER
public NonPersistentMetadataCheckpointStorageLocation(int maxStateSize)
public CheckpointMetadataOutputStream createMetadataOutputStream() throws IOException
CheckpointStorageLocation
createMetadataOutputStream
in interface CheckpointStorageLocation
IOException
- Thrown, if the stream cannot be opened due to an I/O error.public void disposeOnFailure()
CheckpointStorageLocation
disposeOnFailure
in interface CheckpointStorageLocation
public CheckpointStorageLocationReference getLocationReference()
CheckpointStorageLocation
If there is no custom location information that needs to be communicated, this method can
simply return CheckpointStorageLocationReference.getDefault()
.
getLocationReference
in interface CheckpointStorageLocation
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.