I believe SparkEnv.get.serializer would return the serializer created from the "spark.serializer" property.
You can also obtain a Kryo serializer directly via it's no-arg constructor (it still invokes your spark.kryo.registrator): val serializer = new KryoSerializer() but this could have some overhead, and so should probably not be done for every element you process. On Mon, Jan 6, 2014 at 4:36 PM, Aureliano Buendia <[email protected]>wrote: > Hi, > > Is there a way to access the global kryo instance created by spark? I'm > referring to the one which is passed to registerClasses() in a > KryoRegistrator sub class. > > I'd like to access this kryo instance inside a map closure, so it should > be accessible from thw workers side too. >
