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:37 UTC
[06/18] incubator-beam git commit: Add accessors to AfterWatermark
trigger
Add accessors to AfterWatermark trigger
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0df929f9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0df929f9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0df929f9
Branch: refs/heads/master
Commit: 0df929f984c2f5af3d19a4c54635c345ccd5b410
Parents: 2e56517
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Oct 13 21:13:27 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 17 19:56:35 2016 -0700
----------------------------------------------------------------------
.../apache/beam/sdk/transforms/windowing/AfterWatermark.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0df929f9/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
index e2463d8..da96de3 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
@@ -85,6 +85,14 @@ public class AfterWatermark {
@Nullable
private final OnceTrigger lateTrigger;
+ public OnceTrigger getEarlyTrigger() {
+ return earlyTrigger;
+ }
+
+ public OnceTrigger getLateTrigger() {
+ return lateTrigger;
+ }
+
@SuppressWarnings("unchecked")
public AfterWatermarkEarlyAndLate(OnceTrigger earlyTrigger, OnceTrigger lateTrigger) {
super(lateTrigger == null