This closes #1474
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c8f2cdb2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c8f2cdb2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c8f2cdb2 Branch: refs/heads/master Commit: c8f2cdb223cf39d76e733e4dc3fffb5487d41fa4 Parents: 4b68203 aaa3b91 Author: Thomas Groh <tg...@google.com> Authored: Wed Nov 30 15:30:30 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Nov 30 15:30:30 2016 -0800 ---------------------------------------------------------------------- .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 11 +- .../beam/runners/core/PaneInfoTracker.java | 4 - .../runners/core/ReduceFnContextFactory.java | 9 +- .../beam/runners/core/ReduceFnRunner.java | 488 +++++++------------ .../apache/beam/runners/core/WatermarkHold.java | 5 - .../triggers/TriggerStateMachineRunner.java | 14 +- .../beam/runners/core/ReduceFnTester.java | 4 +- .../GroupAlsoByWindowEvaluatorFactory.java | 5 +- .../apache/beam/sdk/transforms/DoFnTester.java | 6 +- .../sdk/util/state/InMemoryTimerInternals.java | 22 +- .../beam/sdk/util/state/TimerCallback.java | 9 +- .../util/state/InMemoryTimerInternalsTest.java | 54 +- 12 files changed, 224 insertions(+), 407 deletions(-) ----------------------------------------------------------------------
