This closes #1101
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c5329f9b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c5329f9b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c5329f9b Branch: refs/heads/master Commit: c5329f9b43c51cf1933d28f88ad44adce96ec7b6 Parents: 7ac7255 0067296 Author: Kenneth Knowles <k...@google.com> Authored: Mon Oct 17 20:37:24 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Oct 17 20:37:24 2016 -0700 ---------------------------------------------------------------------- .../core/triggers/AfterAllStateMachine.java | 5 + .../AfterDelayFromFirstElementStateMachine.java | 17 +- .../core/triggers/AfterEachStateMachine.java | 5 + .../core/triggers/AfterFirstStateMachine.java | 6 + .../core/triggers/AfterPaneStateMachine.java | 7 + .../triggers/AfterWatermarkStateMachine.java | 4 +- .../core/triggers/TriggerStateMachines.java | 210 +++++++++++++++++++ .../core/triggers/TriggerStateMachinesTest.java | 199 ++++++++++++++++++ .../beam/sdk/transforms/windowing/AfterAll.java | 2 +- .../windowing/AfterDelayFromFirstElement.java | 15 ++ .../sdk/transforms/windowing/AfterEach.java | 2 +- .../sdk/transforms/windowing/AfterFirst.java | 2 +- .../sdk/transforms/windowing/AfterPane.java | 7 + .../AfterSynchronizedProcessingTime.java | 6 +- .../transforms/windowing/AfterWatermark.java | 12 +- .../transforms/windowing/DefaultTrigger.java | 2 +- .../beam/sdk/transforms/windowing/Never.java | 8 +- .../transforms/windowing/OrFinallyTrigger.java | 17 +- .../sdk/transforms/windowing/Repeatedly.java | 10 +- .../beam/sdk/transforms/windowing/Trigger.java | 11 +- .../apache/beam/sdk/util/ReshuffleTrigger.java | 2 +- 21 files changed, 528 insertions(+), 21 deletions(-) ----------------------------------------------------------------------