fix compile error of streaming project

explicit return type for implicit function
xiliu82 · Mar 19, 2014 · fe88109 · fe88109
1 parent f9d8a83
commit fe88109
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala
@@ -736,7 +736,7 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])(
 }
 
 object JavaPairDStream {
-  implicit def fromPairDStream[K: ClassTag, V: ClassTag](dstream: DStream[(K, V)]) = {
+  implicit def fromPairDStream[K: ClassTag, V: ClassTag](dstream: DStream[(K, V)]): JavaPairDStream[K, V] = {
     new JavaPairDStream[K, V](dstream)
   }