Skip to content

Commit 11e9c8d

Browse files
author
James Z.M. Gao
committed
fix style error
1 parent fe88109 commit 11e9c8d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -736,7 +736,8 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])(
736736
}
737737

738738
object JavaPairDStream {
739-
implicit def fromPairDStream[K: ClassTag, V: ClassTag](dstream: DStream[(K, V)]): JavaPairDStream[K, V] = {
739+
implicit def fromPairDStream[K: ClassTag, V: ClassTag](dstream: DStream[(K, V)])
740+
: JavaPairDStream[K, V] = {
740741
new JavaPairDStream[K, V](dstream)
741742
}
742743

0 commit comments

Comments
 (0)