Uses of Interface
org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer

Packages that use RecoverableFsDataOutputStream.Committer

Package	Description
org.apache.flink.core.fs
org.apache.flink.core.fs.local

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

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

Modifier and Type	Method	Description
RecoverableFsDataOutputStream.Committer	CommitterFromPersistRecoverableFsDataOutputStream.closeForCommit()
abstract RecoverableFsDataOutputStream.Committer	RecoverableFsDataOutputStream.closeForCommit()	Closes the stream, ensuring persistence of all data (similar to FSDataOutputStream.sync()).
protected abstract RecoverableFsDataOutputStream.Committer	CommitterFromPersistRecoverableFsDataOutputStream.createCommitterFromResumeRecoverable(RESUME_RECOVERABLE recoverable)
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 RecoverableFsDataOutputStream.Committer in org.apache.flink.core.fs.local

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

Modifier and Type	Method	Description
protected RecoverableFsDataOutputStream.Committer	LocalRecoverableFsDataOutputStream.createCommitterFromResumeRecoverable(org.apache.flink.core.fs.local.LocalRecoverable recoverable)
RecoverableFsDataOutputStream.Committer	LocalRecoverableWriter.recoverForCommit(RecoverableWriter.CommitRecoverable recoverable)