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: 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]