Repository: incubator-beam Updated Branches: refs/heads/python-sdk 72fa21f98 -> 7c0bf25fa
Add labels to lambdas in write finalization Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51e97d4a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/51e97d4a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/51e97d4a Branch: refs/heads/python-sdk Commit: 51e97d4a8d3f25608b6ee80f57c973186798d54f Parents: 72fa21f Author: Charles Chen <c...@google.com> Authored: Fri Dec 2 15:17:55 2016 -0800 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Fri Dec 2 22:12:35 2016 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/io/iobase.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/51e97d4a/sdks/python/apache_beam/io/iobase.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/io/iobase.py b/sdks/python/apache_beam/io/iobase.py index b7cac3e..fd6ae57 100644 --- a/sdks/python/apache_beam/io/iobase.py +++ b/sdks/python/apache_beam/io/iobase.py @@ -767,10 +767,10 @@ class WriteImpl(ptransform.PTransform): write_result_coll = (pcoll | core.ParDo('write_bundles', _WriteBundleDoFn(), self.sink, AsSingleton(init_result_coll)) - | core.Map(lambda x: (None, x)) + | core.Map('pair', lambda x: (None, x)) | core.WindowInto(window.GlobalWindows()) | core.GroupByKey() - | core.FlatMap(lambda x: x[1])) + | core.FlatMap('extract', lambda x: x[1])) return do_once | core.FlatMap( 'finalize_write', _finalize_write,
