Repository: incubator-beam Updated Branches: refs/heads/master 7ac725583 -> c5329f9b4
Add access to values from AfterDelay triggers Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b4445ac4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b4445ac4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b4445ac4 Branch: refs/heads/master Commit: b4445ac43530441463ee11c395bcf631b66ef2e9 Parents: 0df929f Author: Kenneth Knowles <k...@google.com> Authored: Thu Oct 13 22:13:43 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Oct 17 19:56:35 2016 -0700 ---------------------------------------------------------------------- .../AfterDelayFromFirstElementStateMachine.java | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b4445ac4/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java index a6616fa..02b156b 100644 --- a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java +++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java @@ -82,7 +82,7 @@ public abstract class AfterDelayFromFirstElementStateMachine extends OnceTrigger */ protected final List<SerializableFunction<Instant, Instant>> timestampMappers; - private final TimeDomain timeDomain; + protected final TimeDomain timeDomain; public AfterDelayFromFirstElementStateMachine( TimeDomain timeDomain, @@ -97,6 +97,21 @@ public abstract class AfterDelayFromFirstElementStateMachine extends OnceTrigger } /** + * The time domain according for which this trigger sets timers. + */ + public TimeDomain getTimeDomain() { + return timeDomain; + } + + /** + * The mapping functions applied to the arrival time of an element to determine when to + * set a wake-up timer for triggering. + */ + public List<SerializableFunction<Instant, Instant>> getTimestampMappers() { + return timestampMappers; + } + + /** * Aligns timestamps to the smallest multiple of {@code size} since the {@code offset} greater * than the timestamp. *
