标签：
《Spark快速大数据分析》
8.4.2 关键性能考量 序列化格式
val conf = new SparkConf().setMaster("local").setAppName("testKryo")
//使用Kryo序列化工具
conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
//严格要求注册类
conf.set("spark.kryo.registrationRequired", "true")
conf.registerKryoClasses(Array(classOf[MyClass], classOf[MyOtherClass]))
val sc = new SparkContext(conf)
标签：
原文地址：http://www.cnblogs.com/ihongyan/p/4979391.html
