fix scala style

freeman-lab · Oct 5, 2014 · 1c2d928 · 1c2d928
1 parent 091b107
commit 1c2d928
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -357,7 +357,8 @@ private[spark] object PythonRDD extends Logging {
     }
   }
 
-  def readBroadcastFromFile(sc: JavaSparkContext, filename: String): Broadcast[Array[Array[Byte]]] = {
+  def readBroadcastFromFile(sc: JavaSparkContext,
+                            filename: String): Broadcast[Array[Array[Byte]]] = {
     val size = new File(filename).length()
     val file = new DataInputStream(new FileInputStream(filename))
     val blockSize = 1 << 20