apache_beam.io.gcp.bigquery_io_read_pipeline module

A Dataflow job that counts the number of rows in a BQ table.

Can be configured to simulate slow reading for a given number of rows.

class apache_beam.io.gcp.bigquery_io_read_pipeline.RowToStringWithSlowDown(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element, num_slow=0, *args, **kwargs)

apache_beam.io.gcp.bigquery_io_read_pipeline.run(argv=None)