网站介绍：文章浏览阅读5.2k次。只做记录，部分结果在代码注释部分：aggregate()：是一个聚合函数，接受多个输入，并按照一定的规则运算以后输出一个结果值getNumPartitions：获取RDD的分区数foreachPartition()：遍历分区中的元素,参数为函数，如下参数为foreach函数，foreach函数中再使用匿名函数 : x=>print(x.toString()+",")此处foreach中匿名函数相当于python中的如下用法：package spark_rddim._aggregation如何获取value值
- 链接地址：https://blog.csdn.net/weixin_46408961/article/details/121064061
- 链接标题：Scala_Spark中aggregate用法以及结果分析_aggregation如何获取value值-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：2394
- 网站标签：aggregation如何获取value值
