Uses of Interface
org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManager
-
Packages that use CheckpointCommittableManager Package Description org.apache.flink.streaming.runtime.operators.sink.committables -
-
Uses of CheckpointCommittableManager 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 CheckpointCommittableManager Modifier and Type Method Description Collection<? extends CheckpointCommittableManager<CommT>>CommittableCollector. getCheckpointCommittablesUpTo(long checkpointId)Returns allCheckpointCommittableManageruntil the requested checkpoint id.
-