diff options
| author | James Z.M. Gao <gaozhm@mediav.com> | 2014-07-16 11:35:21 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-07-16 11:35:21 -0700 |
| commit | caa163f0868776d91697a9041528e382a789f0c3 (patch) | |
| tree | 253146d3cc5f7916d7441f2f0ab95d0e1b4724eb /streaming | |
| parent | 96f28c9726d18f3b0d7a57b128c16ec9157f1532 (diff) | |
| download | spark-caa163f0868776d91697a9041528e382a789f0c3.tar.gz spark-caa163f0868776d91697a9041528e382a789f0c3.tar.bz2 spark-caa163f0868776d91697a9041528e382a789f0c3.zip | |
fix compile error of streaming project
explicit return type for implicit function
Author: James Z.M. Gao <gaozhm@mediav.com>
Closes #153 from gzm55/work/streaming-compile and squashes the following commits:
11e9c8d [James Z.M. Gao] fix style error
fe88109 [James Z.M. Gao] fix compile error of streaming project
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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 c4bdf01fa3..c00e11d119 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 @@ -737,7 +737,8 @@ 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) } |