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 990feacbdc598..dfb5601a9256e 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 @@ -120,7 +120,8 @@ class PythonForeachDStream( * returns the i_th element at the i_th batch under manual clock. */ -class PythonTestInputStream(ssc_ : JavaStreamingContext, inputRDDs: JArrayList[JavaRDD[Array[Byte]]]) +class PythonTestInputStream(ssc_ : JavaStreamingContext, + inputRDDs: JArrayList[JavaRDD[Array[Byte]]]) extends InputDStream[Array[Byte]](JavaStreamingContext.toStreamingContext(ssc_)) { def start() {} @@ -144,4 +145,4 @@ class PythonTestInputStream(ssc_ : JavaStreamingContext, inputRDDs: JArrayList[J } val asJavaDStream = JavaDStream.fromDStream(this) -} \ No newline at end of file +}