Closes #1023
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0d229f5a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0d229f5a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0d229f5a Branch: refs/heads/master Commit: 0d229f5a69059024377202e09eab7d2a2f332a84 Parents: e7684b7 425c778 Author: bchambers <[email protected]> Authored: Fri Sep 30 11:12:39 2016 -0700 Committer: bchambers <[email protected]> Committed: Fri Sep 30 11:12:39 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/core/BatchTimerInternals.java | 140 ----------- .../GroupAlsoByWindowsViaOutputBufferDoFn.java | 7 +- .../beam/runners/core/ReduceFnRunner.java | 3 +- .../runners/core/BatchTimerInternalsTest.java | 118 --------- .../beam/runners/core/ReduceFnTester.java | 248 ++----------------- .../sdk/util/state/InMemoryTimerInternals.java | 235 ++++++++++++++++++ .../util/state/TestInMemoryStateInternals.java | 61 +++++ .../beam/sdk/util/state/TimerCallback.java | 35 +++ .../org/apache/beam/sdk/util/TriggerTester.java | 206 +-------------- .../util/state/InMemoryTimerInternalsTest.java | 116 +++++++++ 10 files changed, 482 insertions(+), 687 deletions(-) ----------------------------------------------------------------------
