apache_beam.io.gcp.big_query_query_to_table_pipeline module

Job that reads and writes data to BigQuery.

A Dataflow job that reads from BQ using a query and then writes to a big query table at the end of the pipeline.

apache_beam.io.gcp.big_query_query_to_table_pipeline.run_bq_pipeline(argv=None)[source]

Run the sample BigQuery pipeline.

Parameters:

argv – Arguments to the run function.