Uses of Interface
org.apache.flink.core.fs.RecoverableWriter.CommitRecoverable

Packages that use RecoverableWriter.CommitRecoverable

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.streaming.api.functions.sink.filesystem

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.core.fs

Subinterfaces of RecoverableWriter.CommitRecoverable in org.apache.flink.core.fs

Modifier and Type	Interface and Description
static interface	RecoverableWriter.ResumeRecoverable A handle to an in-progress stream with a defined and persistent amount of data.

Methods in org.apache.flink.core.fs that return RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableWriter.CommitRecoverable	RecoverableFsDataOutputStream.Committer.getRecoverable() Gets a recoverable object to recover the committer.

Methods in org.apache.flink.core.fs that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	RecoverableWriter.getCommitRecoverableSerializer() The serializer for the CommitRecoverable types created in this writer.

Methods in org.apache.flink.core.fs with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	RecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable resumable) Recovers a recoverable stream consistently at the point indicated by the given CommitRecoverable for finalizing and committing.

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.core.fs.local

Methods in org.apache.flink.core.fs.local that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	LocalRecoverableWriter.getCommitRecoverableSerializer()

Methods in org.apache.flink.core.fs.local with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	LocalRecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable recoverable)

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.fs.azurefs

Methods in org.apache.flink.fs.azurefs with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	AzureBlobRecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable recoverable)

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.fs.gs.writer

Methods in org.apache.flink.fs.gs.writer that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	GSRecoverableWriter.getCommitRecoverableSerializer()

Methods in org.apache.flink.fs.gs.writer with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	GSRecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable resumable)

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.fs.osshadoop.writer

Classes in org.apache.flink.fs.osshadoop.writer that implement RecoverableWriter.CommitRecoverable

Modifier and Type	Class and Description
class	OSSRecoverable Data object to recover an OSS MultiPartUpload for a recoverable output stream.

Methods in org.apache.flink.fs.osshadoop.writer that return RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableWriter.CommitRecoverable	OSSCommitter.getRecoverable()

Methods in org.apache.flink.fs.osshadoop.writer that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	OSSRecoverableWriter.getCommitRecoverableSerializer()

Methods in org.apache.flink.fs.osshadoop.writer with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	OSSRecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable resumable)

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.fs.s3.common.writer

Classes in org.apache.flink.fs.s3.common.writer that implement RecoverableWriter.CommitRecoverable

Modifier and Type	Class and Description
class	S3Recoverable Data object to recover an S3 MultiPartUpload for a recoverable output stream.

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

Modifier and Type	Method and Description
RecoverableWriter.CommitRecoverable	S3Committer.getRecoverable()

Methods in org.apache.flink.fs.s3.common.writer that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	S3RecoverableWriter.getCommitRecoverableSerializer()

Methods in org.apache.flink.fs.s3.common.writer with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	S3RecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable recoverable)

Uses of RecoverableWriter.CommitRecoverable in org.apache.flink.runtime.fs.hdfs

Classes in org.apache.flink.runtime.fs.hdfs that implement RecoverableWriter.CommitRecoverable

Modifier and Type	Class and Description
class	HadoopFsRecoverable An implementation of the resume and commit descriptor objects for Hadoop's/AzureBlob file system abstraction.

Methods in org.apache.flink.runtime.fs.hdfs that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	HadoopRecoverableWriter.getCommitRecoverableSerializer()

Methods in org.apache.flink.runtime.fs.hdfs with parameters of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
RecoverableFsDataOutputStream.Committer	HadoopRecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable recoverable)

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

Methods in org.apache.flink.streaming.api.functions.sink.filesystem that return types with arguments of type RecoverableWriter.CommitRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverableSerializer.getCommitSerializer()

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

Constructor and Description
OutputStreamBasedPendingFileRecoverable(RecoverableWriter.CommitRecoverable commitRecoverable) Deprecated.
OutputStreamBasedPendingFileRecoverable(RecoverableWriter.CommitRecoverable commitRecoverable, Path targetPath, long fileSize)