AzureBlobFsRecoverableDataOutputStream (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- java.io.OutputStream
- - org.apache.flink.core.fs.FSDataOutputStream
  - - org.apache.flink.core.fs.RecoverableFsDataOutputStream
    - - org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream<HadoopFsRecoverable>
      - org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream
        
        org.apache.flink.fs.azurefs.AzureBlobFsRecoverableDataOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable
```
@Internal
public class AzureBlobFsRecoverableDataOutputStream
extends BaseHadoopFsRecoverableFsDataOutputStream
```
An implementation of the RecoverableFsDataOutputStream for AzureBlob's file system abstraction.

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.flink.core.fs.RecoverableFsDataOutputStream
  RecoverableFsDataOutputStream.Committer

Field Summary
- Fields inherited from class org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream
  fs, initialFileSize, out, targetFile, tempFile

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected RecoverableFsDataOutputStream.Committer`	`createCommitterFromResumeRecoverable(HadoopFsRecoverable recoverable)`
`void`	`sync()`	Flushes the data all the way to the persistent non-volatile storage (for example disks).

Methods inherited from class org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream
close, createHadoopFsRecoverable, flush, getPos, persist, write, write

Methods inherited from class org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream
closeForCommit

Methods inherited from class java.io.OutputStream
nullOutputStream, write

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - sync
```
public void sync()
          throws IOException
```
    Description copied from class: FSDataOutputStream
    
    Flushes the data all the way to the persistent non-volatile storage (for example disks). The method behaves similar to the fsync function, forcing all data to be persistent on the devices.
    
    Overrides:
    
    sync in class BaseHadoopFsRecoverableFsDataOutputStream
    
    Throws:
    
    IOException - Thrown if an I/O error occurs
  - createCommitterFromResumeRecoverable
```
protected RecoverableFsDataOutputStream.Committer createCommitterFromResumeRecoverable(HadoopFsRecoverable recoverable)
```
    Specified by:
    
    createCommitterFromResumeRecoverable in class CommitterFromPersistRecoverableFsDataOutputStream<HadoopFsRecoverable>
    
    Parameters:
    
    recoverable - a resume recoverable to create the committer from. Typically the parameter is the return value of CommitterFromPersistRecoverableFsDataOutputStream.persist().
    
    Returns:
    
    the committer created from recoverable.
    
    See Also:
    
    RecoverableFsDataOutputStream.closeForCommit()