From fe88109ca94fcc3445b2e287db12ae1ad4128a40 Mon Sep 17 00:00:00 2001 From: "James Z.M. Gao" Date: Thu, 6 Mar 2014 15:28:18 +0800 Subject: [PATCH 1/2] fix compile error of streaming project explicit return type for implicit function --- .../org/apache/spark/streaming/api/java/JavaPairDStream.scala | 2 +- 1 file changed, 1 insertion(+), 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 index ac451d1913aa..60f8cee501f9 100644 --- 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) } From 11e9c8d8d6b599704db5260eea34ea76baee2cdb Mon Sep 17 00:00:00 2001 From: "James Z.M. Gao" Date: Wed, 19 Mar 2014 11:29:36 +0800 Subject: [PATCH 2/2] fix style error --- .../org/apache/spark/streaming/api/java/JavaPairDStream.scala | 3 ++- 1 file changed, 2 insertions(+), 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 index 60f8cee501f9..16eed7064835 100644 --- 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,8 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])( } object JavaPairDStream { - implicit def fromPairDStream[K: ClassTag, V: ClassTag](dstream: DStream[(K, V)]): JavaPairDStream[K, V] = { + implicit def fromPairDStream[K: ClassTag, V: ClassTag](dstream: DStream[(K, V)]) + : JavaPairDStream[K, V] = { new JavaPairDStream[K, V](dstream) }