Interface CheckpointCommittableManager<CommT>
-
- Type Parameters:
CommT- type of the committable
- All Superinterfaces:
CommittableManager<CommT>
@Internal public interface CheckpointCommittableManager<CommT> extends CommittableManager<CommT>
This interface adds checkpoint meta information to the committable.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description longgetCheckpointId()Returns the checkpoint id in which the committable was created.-
Methods inherited from interface org.apache.flink.streaming.runtime.operators.sink.committables.CommittableManager
commit, getSummary
-
-