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 #2042: Build trigger state machine from Runner API Trigger proto directly
Date Fri, 24 Feb 2017 15:28:53 GMT
This closes #2042: Build trigger state machine from Runner API Trigger proto directly

  Build trigger state machine from Runner API Trigger proto directly
  Factory method best practice for ReshuffleTriggerStateMachine
  Translate ReshuffleTrigger into Always trigger proto
  Add dependency from runners-core-java to runner-api


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

Branch: refs/heads/master
Commit: 25a014f4095c977ac9a98d8d173535bd604f00df
Parents: 3d0fe85 27a482b
Author: Kenneth Knowles <klk@google.com>
Authored: Fri Feb 24 07:17:09 2017 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Fri Feb 24 07:17:09 2017 -0800

----------------------------------------------------------------------
 runners/core-java/pom.xml                       |   5 +
 .../GroupAlsoByWindowViaOutputBufferDoFn.java   |   4 +-
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java |   4 +-
 .../GroupAlsoByWindowViaWindowSetNewDoFn.java   |   4 +-
 .../core/triggers/AfterAllStateMachine.java     |   2 +-
 .../core/triggers/AfterFirstStateMachine.java   |   2 +-
 .../triggers/AfterWatermarkStateMachine.java    |  14 +-
 .../core/triggers/OrFinallyStateMachine.java    |   2 +-
 .../triggers/ReshuffleTriggerStateMachine.java  |   6 +-
 .../core/triggers/TriggerStateMachine.java      |   2 +-
 .../core/triggers/TriggerStateMachines.java     | 272 ++++++-------------
 .../beam/runners/core/ReduceFnTester.java       |   8 +-
 .../ReshuffleTriggerStateMachineTest.java       |   8 +-
 .../core/triggers/TriggerStateMachinesTest.java | 160 +++++++----
 .../GroupAlsoByWindowEvaluatorFactory.java      |   4 +-
 .../translation/SparkGroupAlsoByWindowFn.java   |  40 +--
 .../src/main/proto/beam_runner_api.proto        |   6 +
 .../beam/sdk/transforms/windowing/Triggers.java |   7 +
 18 files changed, 270 insertions(+), 280 deletions(-)
----------------------------------------------------------------------



Mime
View raw message