Skip to content

Commit

Permalink
fix compile error of streaming project
Browse files Browse the repository at this point in the history
explicit return type for implicit function

Author: James Z.M. Gao <gaozhm@mediav.com>

Closes apache#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
  • Loading branch information
James Z.M. Gao committed Jul 17, 2014
1 parent 7d1043c commit b28390d
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}

Expand Down

0 comments on commit b28390d

Please sign in to comment.