apache_beam.io.restriction_trackers module¶
iobase.RestrictionTracker implementations provided with Apache Beam.
-
class
apache_beam.io.restriction_trackers.
OffsetRestrictionTracker
(offset_range)[source]¶ Bases:
apache_beam.io.iobase.RestrictionTracker
An iobase.RestrictionTracker implementations for an offset range.
Offset range is represented as OffsetRange.
-
class
apache_beam.io.restriction_trackers.
UnsplittableRestrictionTracker
(underling_tracker)[source]¶ Bases:
apache_beam.io.iobase.RestrictionTracker
An iobase.RestrictionTracker that wraps another but does not split.