public static interface FileMergingCheckpointStateOutputStream.FileMergingSnapshotManagerProxy
FileMergingSnapshotManager
that owns this FileMergingCheckpointStateOutputStream
, with the interfaces for dealing with physical files.Modifier and Type | Method and Description |
---|---|
SegmentFileStateHandle |
closeStreamAndCreateStateHandle(Path filePath,
long startPos,
long stateSize)
Close the stream and create a
SegmentFileStateHandle for a file segment. |
void |
closeStreamExceptionally()
Notify the
FileMergingSnapshotManager that the stream is closed exceptionally. |
Tuple2<FSDataOutputStream,Path> |
providePhysicalFile()
Provide a physical file.
|
Tuple2<FSDataOutputStream,Path> providePhysicalFile() throws IOException
IOException
- if the physical file cannot be created or opened.SegmentFileStateHandle closeStreamAndCreateStateHandle(Path filePath, long startPos, long stateSize) throws IOException
SegmentFileStateHandle
for a file segment.filePath
- Path of the physical file.startPos
- Start position of the segment in the physical file.stateSize
- Size of the segment.IOException
- if any exception happens when closing the file.void closeStreamExceptionally() throws IOException
FileMergingSnapshotManager
that the stream is closed exceptionally.IOException
- if any exception happens when deleting the file.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.