[javaDocs] Fix JavaDoc examples in tumbling and sliding time windows This closes #1490
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d31b00d3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d31b00d3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d31b00d3 Branch: refs/heads/master Commit: d31b00d3e2dd530fef1b632ea40fe488a48319e9 Parents: 3da24a0 Author: vasia <va...@apache.org> Authored: Wed Jan 6 19:38:34 2016 +0100 Committer: Fabian Hueske <fhue...@apache.org> Committed: Thu Jan 7 17:22:50 2016 +0100 ---------------------------------------------------------------------- .../api/windowing/assigners/SlidingTimeWindows.java | 6 +++--- .../api/windowing/assigners/TumblingTimeWindows.java | 8 ++++---- 2 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d31b00d3/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java index 5f7ab45..4077452 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java @@ -39,9 +39,9 @@ import java.util.List; * For example, in order to window into windows of 1 minute, every 10 seconds: * <pre> {@code * DataStream<Tuple2<String, Integer>> in = ...; - * KeyedStream<String, Tuple2<String, Integer>> keyed = in.keyBy(...); - * WindowedStream<Tuple2<String, Integer>, String, TimeWindows> windowed = - * keyed.window(SlidingTimeWindows.of(Time.of(1, MINUTES), Time.of(10, SECONDS)); + * KeyedStream<Tuple2<String, Integer>, String> keyed = in.keyBy(...); + * WindowedStream<Tuple2<String, Integer>, String, TimeWindow> windowed = + * keyed.window(SlidingTimeWindows.of(Time.minutes(1), Time.seconds(10))); * } </pre> */ public class SlidingTimeWindows extends WindowAssigner<Object, TimeWindow> { http://git-wip-us.apache.org/repos/asf/flink/blob/d31b00d3/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java index 463b2c4..7e5a11f 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java @@ -35,12 +35,12 @@ import java.util.Collections; * elements. Windows cannot overlap. * * <p> - * For example, in order to window into windows of 1 minute, every 10 seconds: + * For example, in order to window into windows of 1 minute: * <pre> {@code * DataStream<Tuple2<String, Integer>> in = ...; - * KeyedStream<String, Tuple2<String, Integer>> keyed = in.keyBy(...); - * WindowedStream<Tuple2<String, Integer>, String, TimeWindows> windowed = - * keyed.window(TumblingTimeWindows.of(Time.of(1, MINUTES), Time.of(10, SECONDS)); + * KeyedStream<Tuple2<String, Integer>, String> keyed = in.keyBy(...); + * WindowedStream<Tuple2<String, Integer>, String, TimeWindow> windowed = + * keyed.window(TumblingTimeWindows.of(Time.minutes(1))); * } </pre> */ public class TumblingTimeWindows extends WindowAssigner<Object, TimeWindow> {
