Class Hierarchy
- java.lang.Object
- cz.o2.proxima.flink.core.batch.OffsetTrackingBatchLogReader (implements cz.o2.proxima.direct.core.batch.BatchLogReader)
- cz.o2.proxima.flink.core.batch.OffsetTrackingBatchLogReader.OffsetTrackingBatchLogObserver (implements cz.o2.proxima.direct.core.batch.BatchLogObserver)
Interface Hierarchy
- java.lang.AutoCloseable
- cz.o2.proxima.direct.core.batch.ObserveHandle
- cz.o2.proxima.flink.core.batch.OffsetTrackingBatchLogReader.OffsetTrackingObserveHandle
- cz.o2.proxima.direct.core.batch.ObserveHandle
- cz.o2.proxima.flink.core.batch.OffsetTrackingBatchLogReader.OffsetCommitter