apache_beam.io.restriction_trackers module

iobase.RestrictionTracker implementations provided with Apache Beam.

class apache_beam.io.restriction_trackers.OffsetRange(start, stop)

Bases: future.types.newobject.newobject

split(desired_num_offsets_per_split, min_num_offsets_per_split=1)

split_at(split_pos)

new_tracker()

size()

class apache_beam.io.restriction_trackers.OffsetRestrictionTracker(offset_range)

Bases: apache_beam.io.iobase.RestrictionTracker

An iobase.RestrictionTracker implementations for an offset range.

Offset range is represented as OffsetRange.

check_done()

current_restriction()

current_watermark()

current_progress()

start_position()

stop_position()

default_size()

try_claim(position)

try_split(fraction_of_remainder)

checkpoint()

defer_remainder(watermark=None)

deferred_status()