diff options
| author | ryanlecompte <lecompte@gmail.com> | 2013-07-24 22:08:09 -0700 |
|---|---|---|
| committer | ryanlecompte <lecompte@gmail.com> | 2013-07-24 22:08:09 -0700 |
| commit | e56aa75de0f3c00e9942f0863c0fb8c57aab5321 (patch) | |
| tree | 9e8f9f5142e9ff77b477bfdfe350db60d3135b07 | |
| parent | 30a369a808cdc16effe9c5755c74fc5a3f3d7cac (diff) | |
| download | spark-e56aa75de0f3c00e9942f0863c0fb8c57aab5321.tar.gz spark-e56aa75de0f3c00e9942f0863c0fb8c57aab5321.tar.bz2 spark-e56aa75de0f3c00e9942f0863c0fb8c57aab5321.zip | |
fix wrapping
| -rw-r--r-- | core/src/main/scala/spark/KryoSerializer.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/KryoSerializer.scala b/core/src/main/scala/spark/KryoSerializer.scala index 2ea90d41c3..eeb2993d8a 100644 --- a/core/src/main/scala/spark/KryoSerializer.scala +++ b/core/src/main/scala/spark/KryoSerializer.scala @@ -27,7 +27,8 @@ import serializer.{SerializerInstance, DeserializationStream, SerializationStrea import spark.broadcast._ import spark.storage._ -private[spark] class KryoSerializationStream(kryo: Kryo, outStream: OutputStream) extends SerializationStream { +private[spark] +class KryoSerializationStream(kryo: Kryo, outStream: OutputStream) extends SerializationStream { val output = new KryoOutput(outStream) def writeObject[T](t: T): SerializationStream = { @@ -39,7 +40,8 @@ private[spark] class KryoSerializationStream(kryo: Kryo, outStream: OutputStream def close() { output.close() } } -private[spark] class KryoDeserializationStream(kryo: Kryo, inStream: InputStream) extends DeserializationStream { +private[spark] +class KryoDeserializationStream(kryo: Kryo, inStream: InputStream) extends DeserializationStream { val input = new KryoInput(inStream) def readObject[T](): T = { |