Uses of Class
org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage
-
Packages that use CommittableWithLineage Package Description org.apache.flink.streaming.runtime.operators.sink.committables -
-
Uses of CommittableWithLineage in org.apache.flink.streaming.runtime.operators.sink.committables
Methods in org.apache.flink.streaming.runtime.operators.sink.committables that return types with arguments of type CommittableWithLineage Modifier and Type Method Description Collection<CommittableWithLineage<CommT>>CommittableManager. commit(boolean fullyReceived, org.apache.flink.api.connector.sink2.Committer<CommT> committer)Commits all due committables.
-