@Internal public class AzureBlobFsRecoverableDataOutputStream extends BaseHadoopFsRecoverableFsDataOutputStream
RecoverableFsDataOutputStream
for AzureBlob's file system
abstraction.RecoverableFsDataOutputStream.Committer
fs, initialFileSize, out, targetFile, tempFile
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream.Committer |
closeForCommit()
Closes the stream, ensuring persistence of all data (similar to
FSDataOutputStream.sync() ). |
void |
sync()
Flushes the data all the way to the persistent non-volatile storage (for example disks).
|
close, createHadoopFsRecoverable, flush, getPos, persist, write, write
write
public void sync() throws IOException
FSDataOutputStream
sync
in class BaseHadoopFsRecoverableFsDataOutputStream
IOException
- Thrown if an I/O error occurspublic RecoverableFsDataOutputStream.Committer closeForCommit() throws IOException
RecoverableFsDataOutputStream
FSDataOutputStream.sync()
). This
returns a Committer that can be used to publish (make visible) the file that the stream was
writing to.closeForCommit
in class BaseHadoopFsRecoverableFsDataOutputStream
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.