org.apache.flink.fs.azurefs

类 AzureBlobFsRecoverableDataOutputStream

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

所有已实现的接口:

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.

嵌套类概要

从类继承的嵌套类/接口 org.apache.flink.core.fs.RecoverableFsDataOutputStream

org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer

字段概要

从类继承的字段 org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream

fs, initialFileSize, out, targetFile, tempFile

方法概要

限定符和类型	方法和说明
protected org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer	createCommitterFromResumeRecoverable(org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable recoverable)
void	sync()

从类继承的方法 org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream

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

从类继承的方法 org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream

closeForCommit

从类继承的方法 java.io.OutputStream

write

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

sync

public void sync()
          throws IOException

覆盖:

sync 在类中 org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream

抛出:

IOException

createCommitterFromResumeRecoverable

protected org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer createCommitterFromResumeRecoverable(org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable recoverable)

指定者:

createCommitterFromResumeRecoverable 在类中 org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream<org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable>