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/06/22 23:04:01 UTC
[9/9] beam git commit: This closes #3425: Fix processing time timer
handling in ReduceFnRunner
This closes #3425: Fix processing time timer handling in ReduceFnRunner
Add tests for corner cases of processing time timers
Add test reproducing BEAM-2505, ignored
Do not GC windows based on processing time timer!
Drop late data in ReduceFnTester
ReduceFnTester assertion for windows that have data buffered
ReduceFnTester can advance clocks without firing timers
Tidy LateDataDroppingDoFnRunner
Add window matcher for pane info
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7645c44b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7645c44b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7645c44b
Branch: refs/heads/master
Commit: 7645c44b9bae9a77192fbe6744918cfb95ca1a3a
Parents: 5506be8 d2b384a
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Jun 22 15:41:02 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Jun 22 15:41:02 2017 -0700
----------------------------------------------------------------------
.../core/LateDataDroppingDoFnRunner.java | 33 ++---
.../beam/runners/core/ReduceFnRunner.java | 3 +-
.../beam/runners/core/SystemReduceFn.java | 6 +
.../beam/runners/core/ReduceFnRunnerTest.java | 136 ++++++++++++++++++-
.../beam/runners/core/ReduceFnTester.java | 48 ++++++-
.../beam/runners/core/WindowMatchers.java | 15 ++
.../beam/sdk/transforms/GroupByKeyTest.java | 39 ++++++
7 files changed, 258 insertions(+), 22 deletions(-)
----------------------------------------------------------------------