Uses of Interface
org.apache.flink.api.connector.sink2.Committer
-
Packages that use Committer Package Description org.apache.flink.api.connector.sink2 -
-
Uses of Committer in org.apache.flink.api.connector.sink2
Methods in org.apache.flink.api.connector.sink2 that return Committer Modifier and Type Method Description Committer<CommittableT>SupportsCommitter. createCommitter(CommitterInitContext context)Creates aCommitterthat permanently makes the previously written data visible throughcommit(Collection).default Committer<CommT>TwoPhaseCommittingSink. createCommitter()Deprecated.default Committer<CommT>TwoPhaseCommittingSink. createCommitter(CommitterInitContext context)Deprecated.Creates aCommitterthat permanently makes the previously written data visible throughcommit(Collection).
-