From d9d59fe4129ff4dee27011101061e93c47c7f30b Mon Sep 17 00:00:00 2001 From: Matthew Farrellee Date: Tue, 26 Aug 2014 17:01:47 -0400 Subject: [PATCH] Fix scalastyle errors --- .../spark/streaming/api/java/JavaStreamingContext.scala | 3 ++- .../apache/spark/streaming/api/python/PythonDStream.scala | 5 +++-- 2 files changed, 5 insertions(+), 3 deletions(-) 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 +}