Re: spark.kryo.classesToRegister

2016-01-28 Thread Jagrut Sharma
code: >> >> >> >> rdd.persist(StorageLevel.MEMORY_ONLY_SER()) >> >> conf.set("spark.serializer","org.apache.spark.serializer.KryoSerializer"); >> >> >> >> Do I compulsorily need to do anything via : spark.kryo.classesToRegister? >> >> Or the above code sufficient to achieve performance gain using Kryo >> serialization? >> >> >> >> Thanks >> >> Amit >> >

Re: spark.kryo.classesToRegister

2016-01-28 Thread Jim Lohse
lizer","org.apache.spark.serializer.KryoSerializer"); Do I compulsorily need to do anything via : spark.kryo.classesToRegister? Or the above code sufficient to achieve performance gain using Kryo serialization? Thanks Amit

Re: spark.kryo.classesToRegister

2016-01-27 Thread Shixiong(Ryan) Zhu
wrote: > This is what I have added in my code: > > > > rdd.persist(StorageLevel.MEMORY_ONLY_SER()) > > conf.set("spark.serializer","org.apache.spark.serializer.KryoSerializer"); > > > > Do I compulsorily need to do anything via : spark.kryo.cla

spark.kryo.classesToRegister

2016-01-27 Thread amit tewari
This is what I have added in my code: rdd.persist(StorageLevel.MEMORY_ONLY_SER()) conf.set("spark.serializer","org.apache.spark.serializer.KryoSerializer"); Do I compulsorily need to do anything via : spark.kryo.classesToRegister? Or the above code sufficient to achi