public interface CheckpointStorageLocation extends CheckpointStreamFactory
CheckpointStorageLocations are typically created and initialized via
CheckpointStorageCoordinatorView.initializeLocationForCheckpoint(long)
or
CheckpointStorageCoordinatorView.initializeLocationForSavepoint(long, String)
.
CheckpointStreamFactory.CheckpointStateOutputStream
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.
|
createCheckpointStateOutputStream
CheckpointMetadataOutputStream createMetadataOutputStream() throws IOException
IOException
- Thrown, if the stream cannot be opened due to an I/O error.void disposeOnFailure() throws IOException
IOException
CheckpointStorageLocationReference getLocationReference()
If there is no custom location information that needs to be communicated,
this method can simply return CheckpointStorageLocationReference.getDefault()
.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.