public class FsCompletedCheckpointStorageLocation extends Object implements CompletedCheckpointStorageLocation
CompletedCheckpointStorageLocation
that resides on a file system. This location is
internally represented through the checkpoint directory plus the metadata file.Constructor and Description |
---|
FsCompletedCheckpointStorageLocation(FileSystem fs,
Path exclusiveCheckpointDir,
FileStateHandle metadataFileHandle,
String externalPointer) |
Modifier and Type | Method and Description |
---|---|
void |
disposeStorageLocation()
Disposes the storage location.
|
Path |
getExclusiveCheckpointDir() |
String |
getExternalPointer()
Gets the external pointer to the checkpoint.
|
FileStateHandle |
getMetadataHandle()
Gets the state handle to the checkpoint's metadata.
|
public FsCompletedCheckpointStorageLocation(FileSystem fs, Path exclusiveCheckpointDir, FileStateHandle metadataFileHandle, String externalPointer)
public String getExternalPointer()
CompletedCheckpointStorageLocation
getExternalPointer
in interface CompletedCheckpointStorageLocation
public Path getExclusiveCheckpointDir()
public FileStateHandle getMetadataHandle()
CompletedCheckpointStorageLocation
getMetadataHandle
in interface CompletedCheckpointStorageLocation
public void disposeStorageLocation() throws IOException
CompletedCheckpointStorageLocation
disposeStorageLocation
in interface CompletedCheckpointStorageLocation
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.