AzureBlobFsRecoverableDataOutputStream (Flink : FileSystems : Azure FS Hadoop 2.1.1-cp2 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<org.apache.flink.runtime.fs.hdfs.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 org.apache.flink.runtime.fs.hdfs.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
  org.apache.flink.core.fs.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 org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer`	`createCommitterFromResumeRecoverable(org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable recoverable)`
`void`	`sync()`

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
```
    Overrides:
    
    sync in class org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream
    
    Throws:
    
    IOException
  - createCommitterFromResumeRecoverable
```
protected org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer createCommitterFromResumeRecoverable(org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable recoverable)
```
    Specified by:
    
    createCommitterFromResumeRecoverable in class org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream<org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable>