Class Hierarchy
- java.lang.Object
- cz.o2.proxima.direct.core.batch.BatchLogObservers
- cz.o2.proxima.direct.core.batch.BatchLogReaders
- cz.o2.proxima.direct.core.batch.BatchLogReaders.ForwardingBatchLogObserver (implements cz.o2.proxima.direct.core.batch.BatchLogObserver)
- cz.o2.proxima.direct.core.batch.BoundedPartition (implements cz.o2.proxima.core.storage.Partition)
- cz.o2.proxima.direct.core.batch.Offset.SimpleOffset (implements cz.o2.proxima.direct.core.batch.Offset)
- cz.o2.proxima.direct.core.batch.TerminationContext (implements cz.o2.proxima.direct.core.batch.ObserveHandle)
Interface Hierarchy
- java.lang.AutoCloseable
- cz.o2.proxima.direct.core.batch.ObserveHandle
- cz.o2.proxima.direct.core.batch.BatchLogReader
- cz.o2.proxima.direct.core.LogObserver<OffsetT,ContextT>
- cz.o2.proxima.direct.core.batch.BatchLogObserver
- java.io.Serializable
- cz.o2.proxima.direct.core.batch.Offset
- cz.o2.proxima.core.functional.TimeProvider
- cz.o2.proxima.core.time.WatermarkSupplier
- cz.o2.proxima.direct.core.LogObserver.OnNextContext<OffsetT>
- cz.o2.proxima.direct.core.batch.BatchLogObserver.OnNextContext
- cz.o2.proxima.direct.core.LogObserver.OnNextContext<OffsetT>
- cz.o2.proxima.core.time.WatermarkSupplier
- cz.o2.proxima.core.functional.UnaryFunction<IN,OUT>
- cz.o2.proxima.direct.core.batch.BatchLogReader.Factory<T>