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

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

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

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 RecoverableFsDataOutputStream

Modifier and Type	Method	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	Description
class	LocalRecoverableFsDataOutputStream	A RecoverableFsDataOutputStream for the LocalFileSystem.

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

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