Uses of Package
org.apache.flink.streaming.runtime.operators.sink.committables
-
Packages that use org.apache.flink.streaming.runtime.operators.sink.committables Package Description org.apache.flink.streaming.runtime.operators.sink.committables -
Classes in org.apache.flink.streaming.runtime.operators.sink.committables used by org.apache.flink.streaming.runtime.operators.sink.committables Class Description CheckpointCommittableManager This interface adds checkpoint meta information to the committable.CommitRequestState Internal state of a committable.CommittableCollector This class is responsible to book-keep the committing progress across checkpoints and subtasks.CommittableManager Internal wrapper to handle the committing of committables.