Package org.apache.flink.fs.azurefs

Class AzureBlobFsRecoverableDataOutputStream

java.lang.Object

java.io.OutputStream

org.apache.flink.core.fs.FSDataOutputStream

org.apache.flink.core.fs.RecoverableFsDataOutputStream

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

Modifier and Type	Method	Description
org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer	closeForCommit()
void	sync()

Methods inherited from class org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream

close, createHadoopFsRecoverable, flush, getPos, persist, write, write

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

closeForCommit

public org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer closeForCommit()
                                                                                throws IOException

Specified by:

closeForCommit in class org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream

Throws:

IOException