Wrapping a few long lines

apache · Feb 25, 2014 · 627a8b7 · 627a8b7
1 parent 0f28ec7
commit 627a8b7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala b/core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala
@@ -23,7 +23,8 @@ import java.nio.ByteBuffer
 import org.apache.spark.SparkConf
 import org.apache.spark.util.ByteBufferInputStream
 
-private[spark] class JavaSerializationStream(out: OutputStream, conf: SparkConf) extends SerializationStream {
+private[spark] class JavaSerializationStream(out: OutputStream,
+                                             conf: SparkConf) extends SerializationStream {
   val objOut = new ObjectOutputStream(out)
   var counter = 0
   val counterReset = conf.getInt("spark.serializer.objectStreamReset", 10000)

diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -489,7 +489,8 @@ private[spark] class BlockManager(
     doPut(blockId, Right(bytes), level, tellMaster)
   }
 
-  private def doPut(blockId: BlockId, data: Either[Either[Iterator[Any],ArrayBuffer[Any]], ByteBuffer],
+  private def doPut(blockId: BlockId,
+                    data: Either[Either[Iterator[Any],ArrayBuffer[Any]], ByteBuffer],
                     level: StorageLevel, tellMaster: Boolean = true): Long = {
     require(blockId != null, "BlockId is null")
     require(level != null && level.isValid, "StorageLevel is null or invalid")