You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/10/13 22:22:51 UTC
[17/17] incubator-beam git commit: This closes #1083
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 <kl...@google.com>
Authored: Thu Oct 13 15:22:08 2016 -0700
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------