Uses of Interface
org.apache.flink.streaming.runtime.operators.sink.committables.CommittableManager

Packages that use CommittableManager

Package	Description
org.apache.flink.streaming.runtime.operators.sink.committables

Uses of CommittableManager in org.apache.flink.streaming.runtime.operators.sink.committables

Subinterfaces of CommittableManager in org.apache.flink.streaming.runtime.operators.sink.committables

Modifier and Type	Interface	Description
interface	CheckpointCommittableManager<CommT>	This interface adds checkpoint meta information to the committable.

Methods in org.apache.flink.streaming.runtime.operators.sink.committables that return CommittableManager

Modifier and Type	Method	Description
CommittableManager<CommT>	CommittableCollector.getEndOfInputCommittable()	Returns CheckpointCommittableManager that is currently hold by the collector and associated with the CommittableCollector.EOI checkpoint id.