You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/04/15 00:23:05 UTC
[2/2] incubator-beam git commit: This closes #150
This closes #150
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5bdea1e2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5bdea1e2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5bdea1e2
Branch: refs/heads/master
Commit: 5bdea1e2bfce7b34a877f198026065b08b36b760
Parents: 6511ba2 c9a1efa
Author: bchambers <bc...@google.com>
Authored: Thu Apr 14 15:09:54 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Thu Apr 14 15:09:54 2016 -0700
----------------------------------------------------------------------
.../transforms/windowing/AfterWatermark.java | 46 +-------
.../beam/sdk/transforms/windowing/Never.java | 76 ++++++++++++
.../apache/beam/sdk/util/IdentityWindowFn.java | 116 +++++++++++++++++++
.../org/apache/beam/sdk/util/Reshuffle.java | 80 ++-----------
.../sdk/transforms/windowing/NeverTest.java | 56 +++++++++
5 files changed, 259 insertions(+), 115 deletions(-)
----------------------------------------------------------------------