diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala index b51d5ff0be9fc..dc71bea59c794 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala @@ -546,7 +546,8 @@ class JavaStreamingContext(val ssc: StreamingContext) { * JavaStreamingContext object contains a number of utility functions. */ object JavaStreamingContext { - implicit def fromStreamingContext(ssc: StreamingContext): JavaStreamingContext = new JavaStreamingContext(ssc) + implicit def fromStreamingContext(ssc: StreamingContext): + JavaStreamingContext = new JavaStreamingContext(ssc) implicit def toStreamingContext(jssc: JavaStreamingContext): StreamingContext = jssc.ssc diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala index a6f4181547f02..3f1bff9b8aa7f 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala @@ -43,8 +43,8 @@ class PythonDStream[T: ClassTag]( preservePartitoning: Boolean, pythonExec: String, broadcastVars: JList[Broadcast[Array[Byte]]], - accumulator: Accumulator[JList[Array[Byte]]]) - extends DStream[Array[Byte]](parent.ssc) { + accumulator: Accumulator[JList[Array[Byte]]] + ) extends DStream[Array[Byte]](parent.ssc) { override def dependencies = List(parent) @@ -70,8 +70,10 @@ class PythonDStream[T: ClassTag]( } -private class PythonPairwiseDStream(prev:DStream[Array[Byte]], partitioner: Partitioner) extends -DStream[Array[Byte]](prev.ssc){ +private class PythonPairwiseDStream( + prev:DStream[Array[Byte]], + partitioner: Partitioner + ) extends DStream[Array[Byte]](prev.ssc){ override def dependencies = List(prev) override def slideDuration: Duration = prev.slideDuration @@ -116,14 +118,14 @@ class PythonForeachDStream( /** * This is a input stream just for the unitest. This is equivalent to a checkpointable, - * replayable, reliable message queue like Kafka. It requires a JArrayList input of JavaRDD, + * replayable, reliable message queue like Kafka. It requires a JArrayList of JavaRDD, * and returns the i_th element at the i_th batch under manual clock. */ class PythonTestInputStream( ssc_ : JavaStreamingContext, - inputRDDs: JArrayList[JavaRDD[Array[Byte]]]) - extends InputDStream[Array[Byte]](JavaStreamingContext.toStreamingContext(ssc_)) { + inputRDDs: JArrayList[JavaRDD[Array[Byte]]] + ) extends InputDStream[Array[Byte]](JavaStreamingContext.toStreamingContext(ssc_)) { def start() {} @@ -146,4 +148,4 @@ class PythonTestInputStream( } val asJavaDStream = JavaDStream.fromDStream(this) -} \ No newline at end of file +}