apache_beam.io.restriction_trackers module¶
iobase.RestrictionTracker implementations provided with Apache Beam.
-
class
apache_beam.io.restriction_trackers.
OffsetRange
(start, stop)[source]¶ Bases:
object
-
class
apache_beam.io.restriction_trackers.
OffsetRestrictionTracker
(offset_range: apache_beam.io.restriction_trackers.OffsetRange)[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.