You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/07/06 21:36:49 UTC
[3/3] beam git commit: This closes #3429: [BEAM-2502,
BEAM-2505] More fixes to ReduceFnRunner.onTimers
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/master
Commit: 628dace9c173182299f322fa6ed974c75dbff4b5
Parents: b8f8d18 935c077
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Jul 6 14:13:56 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
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(-)
----------------------------------------------------------------------