flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject flink git commit: [streaming] [api-breaking] Changed returntype of WindowedDataStream's mapWindow
Date Thu, 07 May 2015 12:28:43 GMT
Repository: flink
Updated Branches:
  refs/heads/master 0078c44e5 -> 689240315


[streaming] [api-breaking] Changed returntype of WindowedDataStream's mapWindow

For a more consistent behaviour.


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

Branch: refs/heads/master
Commit: 68924031594e4793becb884436b0964540f5151c
Parents: 0078c44
Author: mbalassi <mbalassi@apache.org>
Authored: Thu May 7 10:38:31 2015 +0200
Committer: mbalassi <mbalassi@apache.org>
Committed: Thu May 7 14:27:49 2015 +0200

----------------------------------------------------------------------
 .../flink/streaming/api/datastream/WindowedDataStream.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/68924031/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
index 66dd4f3..6f8c347 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
@@ -349,7 +349,7 @@ public class WindowedDataStream<OUT> {
 	 *            The function that will be applied to the windows.
 	 * @return The transformed DataStream
 	 */
-	public <R> WindowedDataStream<R> mapWindow(WindowMapFunction<OUT, R> windowMapFunction)
{
+	public <R> DiscretizedStream<R> mapWindow(WindowMapFunction<OUT, R> windowMapFunction)
{
 		return discretize(WindowTransformation.MAPWINDOW.with(clean(windowMapFunction)),
 				getWindowBuffer(WindowTransformation.MAPWINDOW)).mapWindow(windowMapFunction);
 	}
@@ -372,7 +372,7 @@ public class WindowedDataStream<OUT> {
 	 *            The output type of the operator.
 	 * @return The transformed DataStream
 	 */
-	public <R> WindowedDataStream<R> mapWindow(WindowMapFunction<OUT, R> windowMapFunction,
+	public <R> DiscretizedStream<R> mapWindow(WindowMapFunction<OUT, R> windowMapFunction,
 			TypeInformation<R> outType) {
 
 		return discretize(WindowTransformation.MAPWINDOW.with(windowMapFunction),


Mime
View raw message