说明
将 RDD 的 数据 以 Object对象 的方式,保存到 文件 中,每个分区保存一个文件,分区索引从 00000 开始
文件是二进制的
声明
def saveAsObjectFile(path: String): Unit
例子
val sparConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
val sc = new SparkContext(sparConf)
val rdd:RDD[(String,Int)] = sc.makeRDD( List( ("李雷",10),("韩梅梅",2),("lucy",13) ),2 )
rdd.saveAsObjectFile("res2")
sc.stop()