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 abstract RecoverableFsDataOutputStream.CommitterRecoverableFsDataOutputStream. closeForCommit()Closes the stream, ensuring persistence of all data (similar toFSDataOutputStream.sync()).RecoverableFsDataOutputStream.CommitterRecoverableWriter. 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 RecoverableFsDataOutputStream.CommitterLocalRecoverableFsDataOutputStream. closeForCommit()RecoverableFsDataOutputStream.CommitterLocalRecoverableWriter. recoverForCommit(RecoverableWriter.CommitRecoverable recoverable)
-