ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Allow serializing HttpBroadcast through Kryo

Browse source
This commit is contained in:
root 2012-09-05 08:22:57 +00:00
parent 75487b2f5a
commit efc7668d16
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/src/main/scala/spark/KryoSerializer.scala
View file

@ -13,6 +13,7 @@ import com.esotericsoftware.kryo.serialize.ClassSerializer
import com.esotericsoftware.kryo.serialize.SerializableSerializer
import de.javakaffee.kryoserializers.KryoReflectionFactorySupport
import spark.broadcast._
import spark.storage._
/**
@ -206,6 +207,7 @@ class KryoSerializer extends Serializer with Logging {
// Allow sending SerializableWritable
kryo.register(classOf[SerializableWritable[_]], new SerializableSerializer())
kryo.register(classOf[HttpBroadcast[_]], new SerializableSerializer())
// Register some commonly used Scala singleton objects. Because these
// are singletons, we must return the exact same local object when we