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/12/21 21:59:54 UTC
[5/7] incubator-beam git commit: Add static Window.withOutputTimeFn
to match build method
Add static Window.withOutputTimeFn to match build method
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8188040d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8188040d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8188040d
Branch: refs/heads/master
Commit: 8188040d930b1fa49efd4ed7d5f821d05d6f28ef
Parents: fa4958a
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Dec 20 13:57:55 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Dec 21 13:45:37 2016 -0800
----------------------------------------------------------------------
.../org/apache/beam/sdk/transforms/windowing/Window.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8188040d/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java
index 0c430d0..1241abe 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java
@@ -223,6 +223,15 @@ public class Window {
}
/**
+ * <b><i>(Experimental)</i></b> Override the default {@link OutputTimeFn}, to control
+ * the output timestamp of values output from a {@link GroupByKey} operation.
+ */
+ @Experimental(Kind.OUTPUT_TIME)
+ public static <T> Bound<T> withOutputTimeFn(OutputTimeFn<?> outputTimeFn) {
+ return new Bound(null).withOutputTimeFn(outputTimeFn);
+ }
+
+ /**
* A {@code PTransform} that windows the elements of a {@code PCollection<T>},
* into finite windows according to a user-specified {@code WindowFn}.
*