网站介绍:文章浏览阅读2k次。发现问题object serialDemo { def main(args: Array[String]): Unit = { val sparConf = new SparkConf().setMaster("local").setAppName("WordCount") val sc = new SparkContext(sparConf) val rdd: RDD[String] = sc.makeRDD(Array("hello world", "hello sp_rdd foreach 写文件序列化问题
- 链接地址:https://blog.csdn.net/m0_65025800/article/details/122649767
- 链接标题:【Spark】RDD的序列化问题_rdd foreach 写文件序列化问题-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:1217
- 网站标签:rdd foreach 写文件序列化问题