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 2016/12/03 06:12:48 UTC
[1/2] incubator-beam git commit: Add labels to lambdas in write
finalization
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 <cc...@google.com>
Authored: Fri Dec 2 15:17:55 2016 -0800
Committer: Robert Bradshaw <ro...@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,
[2/2] incubator-beam git commit: Closes #1496
Posted by ro...@apache.org.
Closes #1496
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7c0bf25f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7c0bf25f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7c0bf25f
Branch: refs/heads/python-sdk
Commit: 7c0bf25fadbe2e74ab62c87c90111b8b7c34e297
Parents: 72fa21f 51e97d4
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Fri Dec 2 22:12:36 2016 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Fri Dec 2 22:12:36 2016 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/io/iobase.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------