Package cz.o2.proxima.beam.core.direct.io

Class Summary

Class	Description
BatchLogRead	A PTransform that reads from a BatchLogReader using splittable DoFn.
BatchRestrictionTracker	A RestrictionTracker for Offsets read from CommitLogReader
BatchRestrictionTracker.PartitionList
CommitLogRead	A PTransform that reads from a CommitLogReader using splittable DoFn.
DirectBatchUnboundedSource	Source reading from BatchLogReader in unbounded manner.
DirectBatchUnboundedSource.Checkpoint
DirectBatchUnboundedSource.CheckpointCoder	Use gzip to compress the serialized checkpoint, as it might easily grow in size (batch partitions might contain many files).
DirectDataAccessorFactory	A DataAccessorFactory using DirectDataOperator.
DirectDataAccessorWrapper	Wrapper of direct data accessor to beam one.
OffsetRestrictionTracker	A RestrictionTracker for Offsets read from CommitLogReader
OffsetRestrictionTracker.OffsetRange