fix scala style

Author: davies

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)

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 = _