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/gearpump-runner Commit: 7645c44b9bae9a77192fbe6744918cfb95ca1a3a Parents: 5506be8 d2b384a Author: Kenneth Knowles <[email protected]> Authored: Thu Jun 22 15:41:02 2017 -0700 Committer: Kenneth Knowles <[email protected]> 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(-) ----------------------------------------------------------------------
