Repository: incubator-beam Updated Branches: refs/heads/python-sdk acd8d7952 -> 701aff074
Insert global windowing before write results GBK Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/57a0b6af Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/57a0b6af Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/57a0b6af Branch: refs/heads/python-sdk Commit: 57a0b6af5ef6bde2ba4bb88fe47997f86c5d5e25 Parents: acd8d79 Author: Robert Bradshaw <rober...@gmail.com> Authored: Tue Sep 20 15:24:31 2016 -0700 Committer: GitHub <nore...@github.com> Committed: Tue Sep 20 15:24:31 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/iobase.py | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/57a0b6af/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 ecb8a70..e1f364b 100644 --- a/sdks/python/apache_beam/io/iobase.py +++ b/sdks/python/apache_beam/io/iobase.py @@ -1032,6 +1032,7 @@ class WriteImpl(ptransform.PTransform): _WriteBundleDoFn(), self.sink, AsSingleton(init_result_coll)) | core.Map(lambda x: (None, x)) + | core.WindowInto(window.GlobalWindows()) | core.GroupByKey() | core.FlatMap(lambda x: x[1])) return do_once | core.FlatMap(
