You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by al...@apache.org on 2017/01/30 12:50:19 UTC

[2/2] beam git commit: This closes #1787

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 <al...@gmail.com>
Authored: Mon Jan 30 13:48:19 2017 +0100
Committer: Aljoscha Krettek <al...@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(-)
----------------------------------------------------------------------