This closes #38
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/de91b801 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/de91b801 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/de91b801 Branch: refs/heads/master Commit: de91b801499c60bc781713de129b562163f856d6 Parents: b2b5f42 a1e3d86 Author: Kenneth Knowles <[email protected]> Authored: Thu Mar 10 15:07:52 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Thu Mar 10 15:07:52 2016 -0800 ---------------------------------------------------------------------- .../sdk/util/MergingActiveWindowSet.java | 19 +++++----- .../cloud/dataflow/sdk/util/ReduceFnRunner.java | 10 ++++-- .../dataflow/sdk/util/ReduceFnRunnerTest.java | 37 ++++++++++++++++++++ 3 files changed, 54 insertions(+), 12 deletions(-) ----------------------------------------------------------------------
