This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 065f0bb Update BigQuery source in bigquery_tornadoes example
new f3613e2 Merge pull request #11104 from y1chi/update_tornado_test
065f0bb is described below
commit 065f0bb691852e5c172c3cb4976f05eaebc3efc5
Author: Yichi Zhang <[email protected]>
AuthorDate: Wed Mar 11 16:26:42 2020 -0700
Update BigQuery source in bigquery_tornadoes example
---
sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes.py
b/sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes.py
index 565849c..021e884 100644
--- a/sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes.py
+++ b/sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes.py
@@ -92,7 +92,7 @@ def run(argv=None):
with beam.Pipeline(argv=pipeline_args) as p:
# Read the table rows into a PCollection.
- rows = p | 'read' >> beam.io.Read(beam.io.BigQuerySource(known_args.input))
+ rows = p | 'read' >> beam.io._ReadFromBigQuery(table=known_args.input)
counts = count_tornadoes(rows)
# Write the output using a "Write" transform that has side effects.
