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 <dhalp...@google.com> Authored: Tue Apr 11 16:26:41 2017 -0700 Committer: Dan Halperin <dhalp...@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:
