Uses of Class
org.apache.flink.core.fs.RecoverableFsDataOutputStream

Packages that use RecoverableFsDataOutputStream

Package	Description
org.apache.flink.core.fs
org.apache.flink.core.fs.local
org.apache.flink.fs.azurefs
org.apache.flink.fs.gs.writer
org.apache.flink.fs.osshadoop.writer
org.apache.flink.fs.s3.common.writer
org.apache.flink.runtime.fs.hdfs
org.apache.flink.runtime.state.filesystem
org.apache.flink.streaming.api.functions.sink.filesystem

Uses of RecoverableFsDataOutputStream in org.apache.flink.core.fs

Subclasses of RecoverableFsDataOutputStream in org.apache.flink.core.fs

Modifier and Type

Class and Description

class

CommitterFromPersistRecoverableFsDataOutputStream<RESUME_RECOVERABLE extends RecoverableWriter.ResumeRecoverable> RecoverableFsDataOutputStream with fixed implementation of CommitterFromPersistRecoverableFsDataOutputStream.closeForCommit() that is based on using CommitterFromPersistRecoverableFsDataOutputStream.persist() to ensure durability and creates the RecoverableFsDataOutputStream.Committer from the corresponding RecoverableWriter.ResumeRecoverable.

Methods in org.apache.flink.core.fs that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
RecoverableFsDataOutputStream	RecoverableWriter.open(Path path) Opens a new recoverable stream to write to the given path.
RecoverableFsDataOutputStream	RecoverableWriter.recover(RecoverableWriter.ResumeRecoverable resumable) Resumes a recoverable stream consistently at the point indicated by the given ResumeRecoverable.

Uses of RecoverableFsDataOutputStream in org.apache.flink.core.fs.local

Subclasses of RecoverableFsDataOutputStream in org.apache.flink.core.fs.local

Modifier and Type	Class and Description
class	LocalRecoverableFsDataOutputStream A RecoverableFsDataOutputStream for the LocalFileSystem.

Methods in org.apache.flink.core.fs.local that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
RecoverableFsDataOutputStream	LocalRecoverableWriter.open(Path filePath)
RecoverableFsDataOutputStream	LocalRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

Uses of RecoverableFsDataOutputStream in org.apache.flink.fs.azurefs

Subclasses of RecoverableFsDataOutputStream in org.apache.flink.fs.azurefs

Modifier and Type	Class and Description
class	AzureBlobFsRecoverableDataOutputStream An implementation of the RecoverableFsDataOutputStream for AzureBlob's file system abstraction.

Methods in org.apache.flink.fs.azurefs that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
protected RecoverableFsDataOutputStream	AzureBlobRecoverableWriter.getRecoverableFsDataOutputStream(org.apache.hadoop.fs.Path targetFile, org.apache.hadoop.fs.Path tempFile)
RecoverableFsDataOutputStream	AzureBlobRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

Uses of RecoverableFsDataOutputStream in org.apache.flink.fs.gs.writer

Methods in org.apache.flink.fs.gs.writer that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
RecoverableFsDataOutputStream	GSRecoverableWriter.open(Path path)
RecoverableFsDataOutputStream	GSRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable resumable)

Uses of RecoverableFsDataOutputStream in org.apache.flink.fs.osshadoop.writer

Subclasses of RecoverableFsDataOutputStream in org.apache.flink.fs.osshadoop.writer

Modifier and Type	Class and Description
class	OSSRecoverableFsDataOutputStream A RecoverableFsDataOutputStream to OSS that is based on a recoverable multipart upload.

Methods in org.apache.flink.fs.osshadoop.writer that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
RecoverableFsDataOutputStream	OSSRecoverableWriter.open(Path path)

Uses of RecoverableFsDataOutputStream in org.apache.flink.fs.s3.common.writer

Subclasses of RecoverableFsDataOutputStream in org.apache.flink.fs.s3.common.writer

Modifier and Type	Class and Description
class	S3RecoverableFsDataOutputStream A RecoverableFsDataOutputStream to S3 that is based on a recoverable multipart upload.

Methods in org.apache.flink.fs.s3.common.writer that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
RecoverableFsDataOutputStream	S3RecoverableWriter.open(Path path)

Uses of RecoverableFsDataOutputStream in org.apache.flink.runtime.fs.hdfs

Subclasses of RecoverableFsDataOutputStream in org.apache.flink.runtime.fs.hdfs

Modifier and Type	Class and Description
class	BaseHadoopFsRecoverableFsDataOutputStream Base class for ABFS and Hadoop recoverable stream.

Methods in org.apache.flink.runtime.fs.hdfs that return RecoverableFsDataOutputStream

Modifier and Type	Method and Description
protected RecoverableFsDataOutputStream	HadoopRecoverableWriter.getRecoverableFsDataOutputStream(org.apache.hadoop.fs.Path targetFile, org.apache.hadoop.fs.Path tempFile)
RecoverableFsDataOutputStream	HadoopRecoverableWriter.open(Path filePath)
RecoverableFsDataOutputStream	HadoopRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

Uses of RecoverableFsDataOutputStream in org.apache.flink.runtime.state.filesystem

Constructors in org.apache.flink.runtime.state.filesystem with parameters of type RecoverableFsDataOutputStream

Constructor and Description
RecoverableStreamWrapper(RecoverableFsDataOutputStream out)

Uses of RecoverableFsDataOutputStream in org.apache.flink.streaming.api.functions.sink.filesystem

Methods in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type RecoverableFsDataOutputStream

Modifier and Type	Method and Description
InProgressFileWriter<IN,BucketID>	RowWiseBucketWriter.openNew(BucketID bucketId, RecoverableFsDataOutputStream stream, Path path, long creationTime)
InProgressFileWriter<IN,BucketID>	BulkBucketWriter.openNew(BucketID bucketId, RecoverableFsDataOutputStream stream, Path path, long creationTime)
InProgressFileWriter<IN,BucketID>	RowWiseBucketWriter.resumeFrom(BucketID bucketId, RecoverableFsDataOutputStream stream, Path path, RecoverableWriter.ResumeRecoverable resumable, long creationTime)
InProgressFileWriter<IN,BucketID>	BulkBucketWriter.resumeFrom(BucketID bucketId, RecoverableFsDataOutputStream stream, Path path, RecoverableWriter.ResumeRecoverable resumable, long creationTime)

Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type RecoverableFsDataOutputStream

Constructor and Description
RowWisePartWriter(BucketID bucketId, Path path, RecoverableFsDataOutputStream currentPartStream, Encoder<IN> encoder, long creationTime)