beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [13/18] incubator-beam git commit: Accessors for AfterDelay
Date Tue, 18 Oct 2016 03:38:44 GMT
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 <klk@google.com>
Authored: Thu Oct 13 22:17:14 2016 -0700
Committer: Kenneth Knowles <klk@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.
    *


Mime
View raw message