Permalink
Browse files

Wrapping a few long lines

  • Loading branch information...
1 parent 0f28ec7 commit 627a8b79d760103674f3c5b108900e911a6a7eeb @kellrott kellrott committed Feb 25, 2014
@@ -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)
@@ -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")

0 comments on commit 627a8b7

Please sign in to comment.