flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [FLINK-5360] Fix argument names in WindowedStream
Date Mon, 09 Jan 2017 17:22:25 GMT
Repository: flink
Updated Branches:
  refs/heads/master 36cf7eb2d -> f79944aa8


[FLINK-5360] Fix argument names in WindowedStream


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

Branch: refs/heads/master
Commit: f79944aa8686cf890e4f43830d93245ec96be692
Parents: 36cf7eb
Author: Ivan Mushketyk <ivan.mushketik@gmail.com>
Authored: Fri Dec 16 22:59:21 2016 +0000
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Jan 9 18:19:59 2017 +0100

----------------------------------------------------------------------
 .../streaming/api/datastream/WindowedStream.java  | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f79944aa/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
index 98bf89a..a18a59c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
@@ -833,14 +833,14 @@ public class WindowedStream<T, K, W extends Window> {
 
 	/**
 	 * Applies an aggregation that gives the minimum element of every window of
-	 * the data stream by the given position. If more elements have the same
+	 * the data stream by the given field. If more elements have the same
 	 * minimum value the operator returns the first element by default.
 	 *
-	 * @param positionToMinBy The position to minimize by
+	 * @param field The field to minimize by
 	 * @return The transformed DataStream.
 	 */
-	public SingleOutputStreamOperator<T> minBy(String positionToMinBy) {
-		return this.minBy(positionToMinBy, true);
+	public SingleOutputStreamOperator<T> minBy(String field) {
+		return this.minBy(field, true);
 	}
 
 	/**
@@ -912,15 +912,15 @@ public class WindowedStream<T, K, W extends Window> {
 
 	/**
 	 * Applies an aggregation that gives the maximum element of every window of
-	 * the data stream by the given position. If more elements have the same
+	 * the data stream by the given field. If more elements have the same
 	 * maximum value the operator returns the first by default.
 	 *
-	 * @param positionToMaxBy
-	 *            The position to maximize by
+	 * @param field
+	 *            The field to maximize by
 	 * @return The transformed DataStream.
 	 */
-	public SingleOutputStreamOperator<T> maxBy(String positionToMaxBy) {
-		return this.maxBy(positionToMaxBy, true);
+	public SingleOutputStreamOperator<T> maxBy(String field) {
+		return this.maxBy(field, true);
 	}
 
 	/**


Mime
View raw message