beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [32/43] beam git commit: This closes #3429: [BEAM-2502, BEAM-2505] More fixes to ReduceFnRunner.onTimers
Date Mon, 10 Jul 2017 04:50:02 GMT
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 <klk@google.com>
Authored: Thu Jul 6 14:13:56 2017 -0700
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message