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 #1366
Date Wed, 30 Nov 2016 22:23:03 GMT
This closes #1366


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

Branch: refs/heads/master
Commit: 4a7da91f063c0de07fca250d1016b85832225732
Parents: b75a764 4282c67
Author: Kenneth Knowles <klk@google.com>
Authored: Wed Nov 30 13:32:27 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Wed Nov 30 13:32:27 2016 -0800

----------------------------------------------------------------------
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java |  11 +-
 .../beam/runners/core/PaneInfoTracker.java      |   4 +
 .../runners/core/ReduceFnContextFactory.java    |   9 +-
 .../beam/runners/core/ReduceFnRunner.java       | 488 ++++++++++++-------
 .../apache/beam/runners/core/WatermarkHold.java |   5 +
 .../triggers/TriggerStateMachineRunner.java     |  14 +-
 .../beam/runners/core/ReduceFnTester.java       |   4 +-
 .../GroupAlsoByWindowEvaluatorFactory.java      |   5 +-
 .../apache/beam/sdk/transforms/DoFnTester.java  |   6 +-
 .../sdk/util/state/InMemoryTimerInternals.java  |  22 +-
 .../beam/sdk/util/state/TimerCallback.java      |   9 +-
 .../util/state/InMemoryTimerInternalsTest.java  |  54 +-
 12 files changed, 407 insertions(+), 224 deletions(-)
----------------------------------------------------------------------



Mime
View raw message