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

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	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	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	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	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	Description
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	LocalRecoverableWriter.getResumeRecoverableSerializer()

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

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