From bd278742c59b9d9cd917cd5fd4ca8262aad1f64c Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Thu, 25 Sep 2014 17:34:58 -0700 Subject: [PATCH] fix scala style --- .../src/main/scala/org/apache/spark/api/python/PythonRDD.scala | 3 ++- .../org/apache/spark/streaming/api/python/PythonDStream.scala | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala b/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala index 4cc3350b18c95..034a90110af76 100644 --- a/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala +++ b/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala @@ -53,7 +53,8 @@ private[spark] class PythonRDD( extends RDD[Array[Byte]](parent) { def copyTo(rdd: RDD[_]): PythonRDD = { - new PythonRDD(rdd, command, envVars, pythonIncludes, preservePartitoning, pythonExec, broadcastVars, accumulator) + new PythonRDD(rdd, command, envVars, pythonIncludes, preservePartitoning, + pythonExec, broadcastVars, accumulator) } val bufferSize = conf.getInt("spark.buffer.size", 65536) 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 31e096cce130a..ae5c4ae2958fa 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 @@ -47,7 +47,7 @@ trait PythonRDDFunction { * @param cache */ class PythonTransformedDStream (parent: DStream[_], parent2: DStream[_], func: PythonRDDFunction, - cache: Boolean = false) //TODO: better name + cache: Boolean = false) extends DStream[Array[Byte]] (parent.ssc) { var lastResult: PythonRDD = _