public class FsCheckpointStorageLocation extends FsCheckpointStreamFactory implements CheckpointStorageLocation
FsCheckpointStreamFactory.FsCheckpointStateOutputStream
CheckpointStreamFactory.CheckpointStateOutputStream
MAX_FILE_STATE_THRESHOLD
Constructor and Description |
---|
FsCheckpointStorageLocation(FileSystem fileSystem,
Path checkpointDir,
Path sharedStateDir,
Path taskOwnedStateDir,
CheckpointStorageLocationReference reference,
int fileStateSizeThreshold,
int writeBufferSize) |
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.
|
Path |
getCheckpointDirectory() |
CheckpointStorageLocationReference |
getLocationReference()
Gets a reference to the storage location.
|
Path |
getMetadataFilePath() |
Path |
getSharedStateDirectory() |
Path |
getTaskOwnedStateDirectory() |
String |
toString() |
createCheckpointStateOutputStream
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createCheckpointStateOutputStream
public FsCheckpointStorageLocation(FileSystem fileSystem, Path checkpointDir, Path sharedStateDir, Path taskOwnedStateDir, CheckpointStorageLocationReference reference, int fileStateSizeThreshold, int writeBufferSize)
public Path getCheckpointDirectory()
public Path getSharedStateDirectory()
public Path getTaskOwnedStateDirectory()
public Path getMetadataFilePath()
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() throws IOException
CheckpointStorageLocation
disposeOnFailure
in interface CheckpointStorageLocation
IOException
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
public String toString()
toString
in class FsCheckpointStreamFactory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.