This closes #1477
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/37e891fe Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/37e891fe Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/37e891fe Branch: refs/heads/gearpump-runner Commit: 37e891fe92e51477c4d92a2781a9475f13873a7f Parents: a088449 840fb3b Author: Kenneth Knowles <[email protected]> Authored: Fri Dec 2 13:28:57 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Fri Dec 2 13:28:57 2016 -0800 ---------------------------------------------------------------------- .../operators/ApexGroupByKeyOperator.java | 4 +- .../runners/direct/DirectTimerInternals.java | 4 +- .../apache/beam/sdk/util/TimerInternals.java | 107 +++++++------------ .../sdk/util/state/InMemoryTimerInternals.java | 8 +- .../beam/sdk/util/TimerInternalsTest.java | 4 +- 5 files changed, 49 insertions(+), 78 deletions(-) ----------------------------------------------------------------------
