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.s3.common.writer
org.apache.flink.runtime.fs.hdfs

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

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

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)