beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [12/18] beam git commit: Fix snippets
Date Thu, 12 Oct 2017 22:54:48 GMT
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 <holden@us.ibm.com>
Authored: Wed Oct 11 23:46:28 2017 -0700
Committer: Robert Bradshaw <robertwb@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(


Mime
View raw message