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