apache_beam.io.restriction_trackers module¶

iobase.RestrictionTracker implementations provided with Apache Beam.

class apache_beam.io.restriction_trackers.OffsetRange(start, stop)[source]¶

Bases: future.types.newobject.newobject

split(desired_num_offsets_per_split, min_num_offsets_per_split=1)[source]¶

split_at(split_pos)[source]¶

new_tracker()[source]¶

size()[source]¶

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.

check_done()[source]¶

current_restriction()[source]¶

current_progress()[source]¶

start_position()[source]¶

stop_position()[source]¶

try_claim(position)[source]¶

try_split(fraction_of_remainder)[source]¶