Skip to content

Commit

Permalink
Fix scalastyle errors
Browse files Browse the repository at this point in the history
  • Loading branch information
mattf authored and giwa committed Sep 20, 2014
1 parent c0a06bc commit 2fdf0de
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -549,7 +549,8 @@ class JavaStreamingContext(val ssc: StreamingContext) extends Closeable {
* 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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,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() {}
Expand All @@ -198,4 +199,4 @@ class PythonTestInputStream(ssc_ : JavaStreamingContext, inputRDDs: JArrayList[J
}

val asJavaDStream = JavaDStream.fromDStream(this)
}
}

0 comments on commit 2fdf0de

Please sign in to comment.