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/python-sdk Commit: 8188040d930b1fa49efd4ed7d5f821d05d6f28ef Parents: fa4958a Author: Kenneth Knowles <k...@google.com> Authored: Tue Dec 20 13:57:55 2016 -0800 Committer: Kenneth Knowles <k...@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}. *