网站介绍：文章浏览阅读427次。基础初始化sparkval conf = new SparkConf().setAppName("wordcount")val sc = new SparkContext(conf)转化操作和行动操作的区别在于spark计算rdd的方式不同，只有在第一次在一个行动操作中用到转化操作中的rdd时，才会真正计算这些rdd。创建rdd// 驱动器程序对一个集合进行并行化val lines..._scala中input.aggregate
- 链接地址：https://blog.csdn.net/weixin_42521881/article/details/88115075
- 链接标题：Spark scala api（一）RDD编程_scala中input.aggregate-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：1571
- 网站标签：scala中input.aggregate
