You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/04/06 04:10:46 UTC
[3/3] incubator-beam git commit: This closes #118
This closes #118
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b408b2a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b408b2a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6b408b2a
Branch: refs/heads/master
Commit: 6b408b2a3c57e2859135af50adce6a113132305e
Parents: 1aee017 2c22a05
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Apr 5 19:07:32 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Apr 5 19:07:32 2016 -0700
----------------------------------------------------------------------
.../dataflow/sdk/util/ActiveWindowSet.java | 23 +++-
.../sdk/util/MergingActiveWindowSet.java | 133 +++++++++++--------
.../sdk/util/NonMergingActiveWindowSet.java | 11 +-
.../cloud/dataflow/sdk/util/ReduceFnRunner.java | 65 +++++----
.../cloud/dataflow/sdk/util/TriggerRunner.java | 20 ++-
.../sdk/util/MergingActiveWindowSetTest.java | 23 ++--
.../dataflow/sdk/util/ReduceFnRunnerTest.java | 122 ++++++++++++++++-
.../cloud/dataflow/sdk/util/ReduceFnTester.java | 4 +
.../cloud/dataflow/sdk/util/TriggerTester.java | 2 +-
9 files changed, 294 insertions(+), 109 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b408b2a/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java
----------------------------------------------------------------------