@Internal public class FSDataOutputStreamWrapper extends MetadataOutputStreamWrapper
MetadataOutputStreamWrapper
encapsulates the FSDataOutputStream
for FsCheckpointMetadataOutputStream
.Constructor and Description |
---|
FSDataOutputStreamWrapper(FileSystem fileSystem,
Path metadataFilePath) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
The abstract function of aborting temporary files or doing nothing, which depends on the
different output stream implementations.
|
void |
closeAction()
The abstract function of once closing output stream operation.
|
void |
closeForCommitAction()
The abstract function of once closing output stream and committing operation.
|
FSDataOutputStream |
getOutput()
Returns
FSDataOutputStream to write and other operations. |
public FSDataOutputStreamWrapper(FileSystem fileSystem, Path metadataFilePath) throws IOException
IOException
public FSDataOutputStream getOutput()
MetadataOutputStreamWrapper
FSDataOutputStream
to write and other operations.public void closeForCommitAction() throws IOException
MetadataOutputStreamWrapper
IOException
when failed and should be invoked by closeForCommit()
indirectly
instead of this function.IOException
public void closeAction() throws IOException
MetadataOutputStreamWrapper
IOException
when failed and should be invoked by close()
indirectly instead of this
function.IOException
public void cleanup() throws IOException
MetadataOutputStreamWrapper
IOException
when failed.IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.