@Internal public class RecoverableStreamWrapper extends MetadataOutputStreamWrapper
MetadataOutputStreamWrapper
encapsulates the RecoverableFsDataOutputStream
for FsCheckpointMetadataOutputStream
.Constructor and Description |
---|
RecoverableStreamWrapper(RecoverableFsDataOutputStream out) |
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 RecoverableStreamWrapper(RecoverableFsDataOutputStream out)
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–2023 The Apache Software Foundation. All rights reserved.