Add accessors to Repeatedly 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/303a42ab Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/303a42ab Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/303a42ab Branch: refs/heads/master Commit: 303a42ab993aee70527272dd908c3568a29f1e27 Parents: f46ce0d Author: Kenneth Knowles <k...@google.com> Authored: Thu Oct 13 20:57:48 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Oct 17 19:56:35 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/transforms/windowing/Repeatedly.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/303a42ab/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Repeatedly.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Repeatedly.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Repeatedly.java index 8858798..45bc6c1 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Repeatedly.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Repeatedly.java @@ -49,10 +49,16 @@ public class Repeatedly extends Trigger { return new Repeatedly(repeated); } - private Repeatedly(Trigger repeated) { - super(Arrays.asList(repeated)); + private Trigger repeatedTrigger; + + private Repeatedly(Trigger repeatedTrigger) { + super(Arrays.asList(repeatedTrigger)); + this.repeatedTrigger = repeatedTrigger; } + public Trigger getRepeatedTrigger() { + return repeatedTrigger; + } @Override public void onElement(OnElementContext c) throws Exception {
