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)[source]

Bases: DoFn

process(element, num_slow=0, *args, **kwargs)[source]
apache_beam.io.gcp.bigquery_io_read_pipeline.run(argv=None)[source]