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 <k...@google.com>
Authored: Thu Oct 13 22:17:14 2016 -0700
Committer: Kenneth Knowles <k...@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.
    *

Reply via email to