[javaDocs] Fix JavaDoc examples in tumbling and sliding time windows

This closes apache#1490
spotify · Jan 7, 2016 · d31b00d · d31b00d
1 parent 3da24a0
commit d31b00d
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/.../src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java b/.../src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java
@@ -39,9 +39,9 @@
  * 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> {

diff --git a/...src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java b/...src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java
@@ -35,12 +35,12 @@
  * 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> {