Package cz.o2.proxima.flink.core.batch
-
Interface Summary Interface Description OffsetTrackingBatchLogReader.OffsetCommitter OffsetTrackingBatchLogReader.OffsetTrackingObserveHandle Batch observe handle, that has access to consumed offsets. -
Class Summary Class Description OffsetTrackingBatchLogReader A simple wrapper forbatch log reader, that is able to track the "highest" consumed offset for each partition.OffsetTrackingBatchLogReader.OffsetTrackingBatchLogObserver Log observer, that keeps track of the "highest" consumed offset for each partition.