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/11/17 20:31:14 UTC
[23/50] [abbrv] beam git commit: This closes #3988: [BEAM-3052]
ReduceFnRunner: Do not manage EOW hold or timer, set GC hold and timer always
This closes #3988: [BEAM-3052] ReduceFnRunner: Do not manage EOW hold or timer, set GC hold and timer always
ReduceFnRunner: Do not manage EOW hold or timer, set GC hold and timer always
Truncate the very last fixed window if it goes beyond representable time
Tidy a troublesome TestStreamTest
Fix expectations in CombineTest
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a5254e73
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a5254e73
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a5254e73
Branch: refs/heads/tez-runner
Commit: a5254e730065d8b15899b094ee54011797fffaa1
Parents: 219b9ca 9c994ca
Author: Kenneth Knowles <ke...@apache.org>
Authored: Mon Nov 13 15:03:37 2017 -0800
Committer: Kenneth Knowles <ke...@apache.org>
Committed: Mon Nov 13 15:03:37 2017 -0800
----------------------------------------------------------------------
.../beam/runners/core/ReduceFnRunner.java | 72 ++----
.../apache/beam/runners/core/WatermarkHold.java | 221 +++----------------
.../beam/runners/core/LateDataUtilsTest.java | 2 +-
.../beam/runners/core/ReduceFnRunnerTest.java | 191 ++++++++++++----
.../sdk/transforms/windowing/FixedWindows.java | 24 +-
.../apache/beam/sdk/testing/TestStreamTest.java | 25 ++-
.../apache/beam/sdk/transforms/CombineTest.java | 2 +-
.../transforms/windowing/FixedWindowsTest.java | 12 +
8 files changed, 246 insertions(+), 303 deletions(-)
----------------------------------------------------------------------