beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [5/5] beam git commit: This closes #3988: [BEAM-3052] ReduceFnRunner: Do not manage EOW hold or timer, set GC hold and timer always
Date Mon, 13 Nov 2017 23:32:51 GMT
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/master
Commit: a5254e730065d8b15899b094ee54011797fffaa1
Parents: 219b9ca 9c994ca
Author: Kenneth Knowles <kenn@apache.org>
Authored: Mon Nov 13 15:03:37 2017 -0800
Committer: Kenneth Knowles <kenn@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(-)
----------------------------------------------------------------------



Mime
View raw message