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

Packages that use RecoverableWriter.ResumeRecoverable

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.ResumeRecoverable in org.apache.flink.core.fs

Classes in org.apache.flink.core.fs with type parameters of type RecoverableWriter.ResumeRecoverable

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 RecoverableWriter.ResumeRecoverable

Modifier and Type	Method and Description
abstract RecoverableWriter.ResumeRecoverable	RecoverableFsDataOutputStream.persist() Ensures all data so far is persistent (similar to FSDataOutputStream.sync()) and returns a handle to recover the stream at the current position.

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

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

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

Modifier and Type	Method and Description
boolean	RecoverableWriter.cleanupRecoverableState(RecoverableWriter.ResumeRecoverable resumable) Frees up any resources that were previously occupied in order to be able to recover from a (potential) failure.
RecoverableFsDataOutputStream	RecoverableWriter.recover(RecoverableWriter.ResumeRecoverable resumable) Resumes a recoverable stream consistently at the point indicated by the given ResumeRecoverable.

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

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

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	LocalRecoverableWriter.getResumeRecoverableSerializer()

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

Modifier and Type	Method and Description
boolean	LocalRecoverableWriter.cleanupRecoverableState(RecoverableWriter.ResumeRecoverable resumable)
RecoverableFsDataOutputStream	LocalRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

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

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

Modifier and Type	Method and Description
RecoverableFsDataOutputStream	AzureBlobRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

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

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

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	GSRecoverableWriter.getResumeRecoverableSerializer()

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

Modifier and Type	Method and Description
boolean	GSRecoverableWriter.cleanupRecoverableState(RecoverableWriter.ResumeRecoverable resumable)
RecoverableFsDataOutputStream	GSRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable resumable)

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

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

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.ResumeRecoverable

Modifier and Type	Method and Description
RecoverableWriter.ResumeRecoverable	OSSRecoverableFsDataOutputStream.persist()

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

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	OSSRecoverableWriter.getResumeRecoverableSerializer()

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

Modifier and Type	Method and Description
boolean	OSSRecoverableWriter.cleanupRecoverableState(RecoverableWriter.ResumeRecoverable resumable)
OSSRecoverableFsDataOutputStream	OSSRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable resumable)

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

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

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.ResumeRecoverable

Modifier and Type	Method and Description
RecoverableWriter.ResumeRecoverable	S3RecoverableFsDataOutputStream.persist()

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

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	S3RecoverableWriter.getResumeRecoverableSerializer()

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

Modifier and Type	Method and Description
boolean	S3RecoverableWriter.cleanupRecoverableState(RecoverableWriter.ResumeRecoverable resumable)
S3RecoverableFsDataOutputStream	S3RecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

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

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

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.ResumeRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	HadoopRecoverableWriter.getResumeRecoverableSerializer()

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

Modifier and Type	Method and Description
boolean	HadoopRecoverableWriter.cleanupRecoverableState(RecoverableWriter.ResumeRecoverable resumable)
RecoverableFsDataOutputStream	HadoopRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable)

Uses of RecoverableWriter.ResumeRecoverable 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.ResumeRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer.getResumeSerializer()

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

Modifier and Type	Method and Description
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 RecoverableWriter.ResumeRecoverable

Constructor and Description
OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable resumeRecoverable) Deprecated.
OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable resumeRecoverable, Path targetPath)