This closes #3429: [BEAM-2502, BEAM-2505] More fixes to ReduceFnRunner.onTimers
Process timer firings for a window together Ignore processing time timers in expired windows Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/628dace9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/628dace9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/628dace9 Branch: refs/heads/gearpump-runner Commit: 628dace9c173182299f322fa6ed974c75dbff4b5 Parents: b8f8d18 935c077 Author: Kenneth Knowles <[email protected]> Authored: Thu Jul 6 14:13:56 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Jul 6 14:13:56 2017 -0700 ---------------------------------------------------------------------- .../examples/complete/game/LeaderBoardTest.java | 2 + .../beam/runners/core/ReduceFnRunner.java | 106 +++++++++++++------ .../beam/runners/core/ReduceFnRunnerTest.java | 81 +++++++++++++- 3 files changed, 156 insertions(+), 33 deletions(-) ----------------------------------------------------------------------
