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: apache_beam.transforms.core.DoFn
-
process
(element, num_slow=0, *args, **kwargs)[source]
-
apache_beam.io.gcp.bigquery_io_read_pipeline.
run
(argv=None)[source]