This closes #1083
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e969f3d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e969f3d3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e969f3d3 Branch: refs/heads/master Commit: e969f3d388dda4b991d36e5aa37d5ada71f593e3 Parents: 7322616 a64acb2 Author: Kenneth Knowles <k...@google.com> Authored: Thu Oct 13 15:22:08 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Oct 13 15:22:08 2016 -0700 ---------------------------------------------------------------------- .../core/triggers/AfterAllStateMachine.java | 104 ++++ .../AfterDelayFromFirstElementStateMachine.java | 322 ++++++++++++ .../core/triggers/AfterEachStateMachine.java | 125 +++++ .../core/triggers/AfterFirstStateMachine.java | 106 ++++ .../core/triggers/AfterPaneStateMachine.java | 132 +++++ .../AfterProcessingTimeStateMachine.java | 93 ++++ ...rSynchronizedProcessingTimeStateMachine.java | 63 +++ .../triggers/AfterWatermarkStateMachine.java | 325 ++++++++++++ .../triggers/DefaultTriggerStateMachine.java | 81 +++ .../triggers/ExecutableTriggerStateMachine.java | 160 ++++++ .../runners/core/triggers/FinishedTriggers.java | 44 ++ .../core/triggers/FinishedTriggersBitSet.java | 67 +++ .../core/triggers/FinishedTriggersSet.java | 72 +++ .../core/triggers/NeverStateMachine.java | 60 +++ .../core/triggers/OrFinallyStateMachine.java | 85 ++++ .../core/triggers/RepeatedlyStateMachine.java | 88 ++++ .../triggers/ReshuffleTriggerStateMachine.java | 50 ++ .../core/triggers/TriggerStateMachine.java | 487 ++++++++++++++++++ .../TriggerStateMachineContextFactory.java | 509 +++++++++++++++++++ .../triggers/TriggerStateMachineRunner.java | 234 +++++++++ .../runners/core/triggers/package-info.java | 23 + .../core/triggers/AfterAllStateMachineTest.java | 140 +++++ .../triggers/AfterEachStateMachineTest.java | 108 ++++ .../triggers/AfterFirstStateMachineTest.java | 159 ++++++ .../triggers/AfterPaneStateMachineTest.java | 117 +++++ .../AfterProcessingTimeStateMachineTest.java | 172 +++++++ ...chronizedProcessingTimeStateMachineTest.java | 110 ++++ .../AfterWatermarkStateMachineTest.java | 382 ++++++++++++++ .../DefaultTriggerStateMachineTest.java | 165 ++++++ .../ExecutableTriggerStateMachineTest.java | 108 ++++ .../triggers/FinishedTriggersBitSetTest.java | 55 ++ .../triggers/FinishedTriggersProperties.java | 115 +++++ .../core/triggers/FinishedTriggersSetTest.java | 60 +++ .../core/triggers/NeverStateMachineTest.java | 59 +++ .../triggers/OrFinallyStateMachineTest.java | 177 +++++++ .../triggers/RepeatedlyStateMachineTest.java | 200 ++++++++ .../ReshuffleTriggerStateMachineTest.java | 68 +++ .../core/triggers/StubTriggerStateMachine.java | 60 +++ .../core/triggers/TriggerStateMachineTest.java | 98 ++++ .../triggers/TriggerStateMachineTester.java | 431 ++++++++++++++++ .../beam/sdk/util/ExecutableTriggerTest.java | 127 ----- .../sdk/util/FinishedTriggersBitSetTest.java | 55 -- .../sdk/util/FinishedTriggersProperties.java | 110 ---- .../beam/sdk/util/FinishedTriggersSetTest.java | 60 --- .../beam/sdk/util/ReshuffleTriggerTest.java | 67 --- 45 files changed, 6014 insertions(+), 419 deletions(-) ----------------------------------------------------------------------
