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 0df4431 Revert "Merge pull request #11104 from
y1chi/update_tornado_test"
new aeab2db Merge pull request #11284 from Revert "Merge pull request
#11104 from y1chi/update_tornado_test"
0df4431 is described below
commit 0df4431098d8f5a93813216355c6cda4cff11311
Author: Pablo Estrada <[email protected]>
AuthorDate: Wed Apr 1 15:42:57 2020 -0700
Revert "Merge pull request #11104 from y1chi/update_tornado_test"
This reverts commit f3613e2774042abfc124df908faa72aedb3e7463, reversing
changes made to cf7ca7cabc292fa7501372660c75aa2a1c4fe790.
---
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 021e884..565849c 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._ReadFromBigQuery(table=known_args.input)
+ rows = p | 'read' >> beam.io.Read(beam.io.BigQuerySource(known_args.input))
counts = count_tornadoes(rows)
# Write the output using a "Write" transform that has side effects.
