You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2016/01/07 19:01:21 UTC
[2/3] flink git commit: [javaDocs] Fix JavaDoc examples in tumbling
and sliding time windows
[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/61762486
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/61762486
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/61762486
Branch: refs/heads/release-0.10
Commit: 61762486d2699c8b60001a163ebe7086e93d4d64
Parents: 9feac5a
Author: vasia <va...@apache.org>
Authored: Wed Jan 6 19:38:34 2016 +0100
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Jan 7 19:00:48 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/61762486/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/61762486/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> {