You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/10/12 22:54:48 UTC
[12/18] beam git commit: Fix snippets
Fix snippets
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9de10e2d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9de10e2d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9de10e2d
Branch: refs/heads/master
Commit: 9de10e2d80ce15c5881b26f6436d28cccf60e18b
Parents: 3a04dbe
Author: Holden Karau <ho...@us.ibm.com>
Authored: Wed Oct 11 23:46:28 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Thu Oct 12 15:53:55 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/examples/snippets/snippets.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/9de10e2d/sdks/python/apache_beam/examples/snippets/snippets.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/examples/snippets/snippets.py b/sdks/python/apache_beam/examples/snippets/snippets.py
index 048b31a..a7751a7 100644
--- a/sdks/python/apache_beam/examples/snippets/snippets.py
+++ b/sdks/python/apache_beam/examples/snippets/snippets.py
@@ -1179,9 +1179,9 @@ def model_co_group_by_key_tuple(email_list, phone_list, output_path):
return '%s; %s; %s' %\
(name, sorted(info['emails']), sorted(info['phones']))
- contact_lines = result | beam.Map(join_info)
+ contact_lines = results | beam.Map(join_info)
# [END model_group_by_key_cogroupbykey_tuple]
- formatted_results | beam.io.WriteToText(output_path)
+ contact_lines | beam.io.WriteToText(output_path)
def model_join_using_side_inputs(