I was able to get this working by extending KryoRegistrator and setting the "spark.kryo.registrator" property.
On Thu, Feb 12, 2015 at 12:31 PM, Corey Nolet <cjno...@gmail.com> wrote: > I'm trying to register a custom class that extends Kryo's Serializer > interface. I can't tell exactly what Class the registerKryoClasses() > function on the SparkConf is looking for. > > How do I register the Serializer class? >
