flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [6/6] flink git commit: [hotfix][docs] Drop the incorrect parallel remark in windowAll
Date Mon, 05 Mar 2018 16:54:45 GMT
[hotfix][docs] Drop the incorrect parallel remark in windowAll

This closes #5607.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/128127a2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/128127a2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/128127a2

Branch: refs/heads/master
Commit: 128127a2410c84eef1442093e51b7e79e53f6b1b
Parents: 92cf937
Author: Piotr Nowojski <piotr.nowojski@gmail.com>
Authored: Thu Mar 1 10:40:20 2018 +0100
Committer: zentol <chesnay@apache.org>
Committed: Mon Mar 5 17:54:28 2018 +0100

----------------------------------------------------------------------
 .../streaming/api/datastream/DataStream.java    | 25 ++++++++------------
 1 file changed, 10 insertions(+), 15 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/128127a2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index a357eda..7fecdb0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -717,9 +717,8 @@ public class DataStream<T> {
 	 * {@code .window(TumblingProcessingTimeWindows.of(size))} depending on the time characteristic
 	 * set using
 	 *
-	 * <p>Note: This operation can be inherently non-parallel since all elements have
to pass through
-	 * the same operator instance. (Only for special cases, such as aligned time windows is
-	 * it possible to perform this operation in parallel).
+	 * <p>Note: This operation is inherently non-parallel since all elements have to pass
through
+	 * the same operator instance.
 	 *
 	 * {@link org.apache.flink.streaming.api.environment.StreamExecutionEnvironment#setStreamTimeCharacteristic(org.apache.flink.streaming.api.TimeCharacteristic)}
 	 *
@@ -741,9 +740,8 @@ public class DataStream<T> {
 	 * set using
 	 * {@link org.apache.flink.streaming.api.environment.StreamExecutionEnvironment#setStreamTimeCharacteristic(org.apache.flink.streaming.api.TimeCharacteristic)}
 	 *
-	 * <p>Note: This operation can be inherently non-parallel since all elements have
to pass through
-	 * the same operator instance. (Only for special cases, such as aligned time windows is
-	 * it possible to perform this operation in parallel).
+	 * <p>Note: This operation is inherently non-parallel since all elements have to pass
through
+	 * the same operator instance.
 	 *
 	 * @param size The size of the window.
 	 */
@@ -758,9 +756,8 @@ public class DataStream<T> {
 	/**
 	 * Windows this {@code DataStream} into tumbling count windows.
 	 *
-	 * <p>Note: This operation can be inherently non-parallel since all elements have
to pass through
-	 * the same operator instance. (Only for special cases, such as aligned time windows is
-	 * it possible to perform this operation in parallel).
+	 * <p>Note: This operation is inherently non-parallel since all elements have to pass
through
+	 * the same operator instance.
 	 *
 	 * @param size The size of the windows in number of elements.
 	 */
@@ -771,9 +768,8 @@ public class DataStream<T> {
 	/**
 	 * Windows this {@code DataStream} into sliding count windows.
 	 *
-	 * <p>Note: This operation can be inherently non-parallel since all elements have
to pass through
-	 * the same operator instance. (Only for special cases, such as aligned time windows is
-	 * it possible to perform this operation in parallel).
+	 * <p>Note: This operation is inherently non-parallel since all elements have to pass
through
+	 * the same operator instance.
 	 *
 	 * @param size The size of the windows in number of elements.
 	 * @param slide The slide interval in number of elements.
@@ -794,9 +790,8 @@ public class DataStream<T> {
 	 * when windows are evaluated. However, {@code WindowAssigners} have a default {@code Trigger}
 	 * that is used if a {@code Trigger} is not specified.
 	 *
-	 * <p>Note: This operation can be inherently non-parallel since all elements have
to pass through
-	 * the same operator instance. (Only for special cases, such as aligned time windows is
-	 * it possible to perform this operation in parallel).
+	 * <p>Note: This operation is inherently non-parallel since all elements have to pass
through
+	 * the same operator instance.
 	 *
 	 * @param assigner The {@code WindowAssigner} that assigns elements to windows.
 	 * @return The trigger windows data stream.


Mime
View raw message