apache_beam.io.utils module¶

Utils for the io library. * CountingSource: Subclass of iobase.BoundedSource. Used on transforms.ptransform_test.test_read_metrics.

class apache_beam.io.utils.CountingSource(count)[source]¶

Bases: apache_beam.io.iobase.BoundedSource

estimate_size()[source]¶

get_range_tracker(start_position, stop_position)[source]¶

read(range_tracker)[source]¶

split(desired_bundle_size, start_position=None, stop_position=None)[source]¶