fix scala style

YanTangZhai · Sep 26, 2014 · bd27874 · bd27874
1 parent 7339be0
commit bd27874
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 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
@@ -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
@@ -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 = _