Repository: beam Updated Branches: refs/heads/master cd77033b5 -> 60834a903
Update user_score.py Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/46a20cb0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/46a20cb0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/46a20cb0 Branch: refs/heads/master Commit: 46a20cb0f5d53ca4dd9fcaf80271d9069e13cd90 Parents: cd77033 Author: Stephen Sisk <[email protected]> Authored: Thu Apr 13 11:23:03 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Thu Apr 13 13:20:33 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/examples/complete/game/user_score.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/46a20cb0/sdks/python/apache_beam/examples/complete/game/user_score.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/examples/complete/game/user_score.py b/sdks/python/apache_beam/examples/complete/game/user_score.py index 1ebf893..27b60cb 100644 --- a/sdks/python/apache_beam/examples/complete/game/user_score.py +++ b/sdks/python/apache_beam/examples/complete/game/user_score.py @@ -30,8 +30,9 @@ calculates the sum of scores per user, over an entire batch of gaming data data that arrives after the day's cutoff point. To execute this pipeline using the static example input data, specify the -`--dataset=YOUR-DATASET` flag along with other runner specific flags. (Note: -BigQuery dataset you specify must already exist.) +`--dataset=YOUR-DATASET` flag along with other runner specific flags. Note: +The BigQuery dataset you specify must already exist. You can simply create a new +empty BigQuery dataset if you don't have an existing one. Optionally include the `--input` argument to specify a batch input file. See the `--input` default value for an example batch data file.
