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:44 UTC
[13/18] incubator-beam git commit: Accessors for AfterDelay
Accessors for AfterDelay
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fa9b3812
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fa9b3812
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fa9b3812
Branch: refs/heads/master
Commit: fa9b3812e7262b1e0368f613d3f667b71f5de59e
Parents: e1c5bfb
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Oct 13 22:17:14 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 17 19:56:36 2016 -0700
----------------------------------------------------------------------
.../windowing/AfterDelayFromFirstElement.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fa9b3812/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.java
index c4bc946..6078b34 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.java
@@ -97,6 +97,21 @@ public abstract class AfterDelayFromFirstElement 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.
*