@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 |
---|---|
protected RecoverableFsDataOutputStream.Committer |
createCommitterFromResumeRecoverable(HadoopFsRecoverable recoverable) |
void |
sync()
Flushes the data all the way to the persistent non-volatile storage (for example disks).
|
close, createHadoopFsRecoverable, flush, getPos, persist, write, write
closeForCommit
write
public void sync() throws IOException
FSDataOutputStream
sync
in class BaseHadoopFsRecoverableFsDataOutputStream
IOException
- Thrown if an I/O error occursprotected RecoverableFsDataOutputStream.Committer createCommitterFromResumeRecoverable(HadoopFsRecoverable recoverable)
createCommitterFromResumeRecoverable
in class CommitterFromPersistRecoverableFsDataOutputStream<HadoopFsRecoverable>
recoverable
- a resume recoverable to create the committer from. Typically the parameter
is the return value of CommitterFromPersistRecoverableFsDataOutputStream.persist()
.RecoverableFsDataOutputStream.closeForCommit()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.