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