beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/2] incubator-beam git commit: This closes #1519
Date Tue, 06 Dec 2016 21:55:52 GMT
This closes #1519


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c72708cd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c72708cd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c72708cd

Branch: refs/heads/master
Commit: c72708cd2c5725a739a4198bcede1560812bb5af
Parents: 9d380de 2b044f3
Author: Kenneth Knowles <klk@google.com>
Authored: Tue Dec 6 13:55:32 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Tue Dec 6 13:55:32 2016 -0800

----------------------------------------------------------------------
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java |  11 +-
 .../GroupAlsoByWindowsViaOutputBufferDoFn.java  |  48 +-
 .../beam/runners/core/PaneInfoTracker.java      |   4 +
 .../runners/core/ReduceFnContextFactory.java    |   9 +-
 .../beam/runners/core/ReduceFnRunner.java       | 493 ++++++++++++-------
 .../apache/beam/runners/core/WatermarkHold.java |   5 +
 .../triggers/TriggerStateMachineRunner.java     |  14 +-
 .../beam/runners/core/ReduceFnTester.java       |  77 ++-
 .../triggers/TriggerStateMachineTester.java     |  17 +-
 .../GroupAlsoByWindowEvaluatorFactory.java      |   5 +-
 10 files changed, 440 insertions(+), 243 deletions(-)
----------------------------------------------------------------------



Mime
View raw message