You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/04/12 01:34:21 UTC
[1/2] beam git commit: Triggers: handle missing case
Repository: beam
Updated Branches:
refs/heads/master ccf247c1d -> 82f2f2cff
Triggers: handle missing case
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e7f43372
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e7f43372
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e7f43372
Branch: refs/heads/master
Commit: e7f433720e229dcc296d279c459ed65c08fbb531
Parents: ccf247c
Author: Dan Halperin <dh...@google.com>
Authored: Tue Apr 11 16:26:41 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Tue Apr 11 16:26:41 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/transforms/windowing/Triggers.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/e7f43372/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
index ec82114..591af37 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
@@ -287,6 +287,8 @@ public class Triggers implements Serializable {
return trigger;
case AFTER_SYNCHRONIZED_PROCESSING_TIME:
return AfterSynchronizedProcessingTime.ofFirstElement();
+ case ALWAYS:
+ return new ReshuffleTrigger();
case ELEMENT_COUNT:
return AfterPane.elementCountAtLeast(triggerProto.getElementCount().getElementCount());
case NEVER:
[2/2] beam git commit: This closes #2504
Posted by dh...@apache.org.
This closes #2504
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/82f2f2cf
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/82f2f2cf
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/82f2f2cf
Branch: refs/heads/master
Commit: 82f2f2cff0f026800df465f1bff5451a7891ee13
Parents: ccf247c e7f4337
Author: Dan Halperin <dh...@google.com>
Authored: Tue Apr 11 18:34:14 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Tue Apr 11 18:34:14 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/transforms/windowing/Triggers.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------