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 <k...@google.com> Authored: Tue Apr 5 19:07:32 2016 -0700 Committer: Kenneth Knowles <k...@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 ----------------------------------------------------------------------
