flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject [7/7] flink git commit: [FLINK-2088] [streaming] [scala] DataStream.name() returns a typed DataStream
Date Thu, 28 May 2015 13:36:33 GMT
[FLINK-2088] [streaming] [scala] DataStream.name() returns a typed DataStream

Closes #739


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

Branch: refs/heads/master
Commit: 7f5edeb9a7fa7e8a279634437be36cf3594a67b1
Parents: a302817
Author: mbalassi <mbalassi@apache.org>
Authored: Thu May 28 09:58:40 2015 +0200
Committer: mbalassi <mbalassi@apache.org>
Committed: Thu May 28 14:45:47 2015 +0200

----------------------------------------------------------------------
 .../scala/org/apache/flink/streaming/api/scala/DataStream.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/7f5edeb9/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
b/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
index 89fd999..3618c49 100644
--- a/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
+++ b/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
@@ -93,7 +93,7 @@ class DataStream[T](javaStream: JavaStream[T]) {
    *
    * @return The named operator
    */
-  def name(name: String) : DataStream[_] = javaStream match {
+  def name(name: String) : DataStream[T] = javaStream match {
     case stream : SingleOutputStreamOperator[_,_] => javaStream.name(name)
     case _ => throw new
         UnsupportedOperationException("Only supported for operators.")


Mime
View raw message