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

split(desired_num_offsets_per_split, min_num_offsets_per_split=1)[source]
split_at(split_pos) → Tuple[OffsetRange, OffsetRange][source]
new_tracker()[source]
size()[source]
class apache_beam.io.restriction_trackers.OffsetRestrictionTracker(offset_range: OffsetRange)[source]

Bases: RestrictionTracker

An iobase.RestrictionTracker implementations for an offset range.

Offset range is represented as OffsetRange.

check_done()[source]
current_restriction()[source]
current_progress() → RestrictionProgress[source]
start_position()[source]
stop_position()[source]
try_claim(position)[source]
try_split(fraction_of_remainder)[source]
is_bounded()[source]
class apache_beam.io.restriction_trackers.UnsplittableRestrictionTracker(underling_tracker)[source]

Bases: RestrictionTracker

An iobase.RestrictionTracker that wraps another but does not split.

try_split(fraction_of_remainder)[source]