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 <k...@google.com> Authored: Thu Oct 13 21:13:27 2016 -0700 Committer: Kenneth Knowles <k...@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