beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [17/17] incubator-beam git commit: This closes #1083
Date Thu, 13 Oct 2016 22:22:51 GMT
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 <klk@google.com>
Authored: Thu Oct 13 15:22:08 2016 -0700
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message