This closes #1870
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f29527f6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f29527f6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f29527f6 Branch: refs/heads/master Commit: f29527f68b8de92caf18b183e3a7e97eb190f67e Parents: 27cf68e 38575a1 Author: Davor Bonaci <da...@google.com> Authored: Mon Jan 30 12:38:53 2017 -0800 Committer: Davor Bonaci <da...@google.com> Committed: Mon Jan 30 12:38:53 2017 -0800 ---------------------------------------------------------------------- .../GroupAlsoByWindowViaWindowSetNewDoFn.java | 156 +++++++++++++++++++ .../wrappers/streaming/DoFnOperator.java | 69 ++++---- .../wrappers/streaming/WindowDoFnOperator.java | 143 +++++++++-------- sdks/python/apache_beam/version.py | 3 +- 4 files changed, 265 insertions(+), 106 deletions(-) ----------------------------------------------------------------------