This closes #1787
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/582c4a8a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/582c4a8a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/582c4a8a Branch: refs/heads/master Commit: 582c4a8a4dd33d698beae2990d682848b593de21 Parents: 34b4a6d 1dcda72 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Mon Jan 30 13:48:19 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Mon Jan 30 13:48:19 2017 +0100 ---------------------------------------------------------------------- .../GroupAlsoByWindowViaWindowSetNewDoFn.java | 156 +++++++++++++++++++ .../wrappers/streaming/DoFnOperator.java | 69 ++++---- .../wrappers/streaming/WindowDoFnOperator.java | 143 +++++++++-------- 3 files changed, 264 insertions(+), 104 deletions(-) ----------------------------------------------------------------------
