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:39 UTC
[08/18] incubator-beam git commit: Construct AfterFirstStateMachine
with a list of subtriggers
Construct AfterFirstStateMachine with a list of subtriggers
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77332f1e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77332f1e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/77332f1e
Branch: refs/heads/master
Commit: 77332f1e612caf9090e148e1493c11ca8e753076
Parents: b2bb7c0
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Oct 13 20:43:08 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 17 19:56:35 2016 -0700
----------------------------------------------------------------------
.../beam/runners/core/triggers/AfterFirstStateMachine.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/77332f1e/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java
----------------------------------------------------------------------
diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java
index 272c278..f4b305e 100644
--- a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java
+++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java
@@ -20,6 +20,7 @@ package org.apache.beam.runners.core.triggers;
import static com.google.common.base.Preconditions.checkArgument;
import com.google.common.base.Joiner;
+import com.google.common.collect.ImmutableList;
import java.util.Arrays;
import java.util.List;
import org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine;
@@ -46,6 +47,11 @@ public class AfterFirstStateMachine extends OnceTriggerStateMachine {
return new AfterFirstStateMachine(Arrays.<TriggerStateMachine>asList(triggers));
}
+ public static OnceTriggerStateMachine of(
+ Iterable<? extends TriggerStateMachine> triggers) {
+ return new AfterFirstStateMachine(ImmutableList.copyOf(triggers));
+ }
+
@Override
public void onElement(OnElementContext c) throws Exception {
for (ExecutableTriggerStateMachine subTrigger : c.trigger().subTriggers()) {