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/18 03:38:49 UTC
[18/18] incubator-beam git commit: This closes #1101
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 <kl...@google.com>
Authored: Mon Oct 17 20:37:24 2016 -0700
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------