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 <k...@google.com> Authored: Fri Feb 24 07:17:09 2017 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------
