Package cz.o2.proxima.direct.core.batch

Interface Summary

Interface	Description
BatchLogObserver	Batch observer of data.
BatchLogObserver.OnNextContext	Context passed to LogObserver.onNext(cz.o2.proxima.core.storage.StreamElement, ContextT).
BatchLogReader	Reader of batch data stored in batch storage.
BatchLogReader.Factory<T extends BatchLogReader>	Serializable factory for BatchLogReader.
ObserveHandle	A interface for handling progress and control consumption of running observe process.
Offset	Offset representing a "pointer" to an element within a batch partition.

Class Summary

Class	Description
BatchLogObservers	Utility class related to BatchLogObservers.
BatchLogReaders	Class constructing various BatchLogReaders.
BatchLogReaders.ForwardingBatchLogObserver
BoundedPartition	Bounded implementation of Partition.
Offset.SimpleOffset
TerminationContext	A context that guards correct termination of batch observation process.