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]
new_tracker()[source]
class apache_beam.io.restriction_trackers.OffsetRestrictionTracker(start_position, stop_position)[source]

Bases: apache_beam.io.iobase.RestrictionTracker

An iobase.RestrictionTracker implementations for an offset range.

Offset range is represented as a pair of integers [start_position, stop_position}.

check_done()[source]
current_restriction()[source]
current_watermark()[source]
start_position()[source]
stop_position()[source]
try_claim(position)[source]
try_split(fraction)[source]
checkpoint()[source]
defer_remainder(watermark=None)[source]
deferred_status()[source]