- 链接地址:https://blog.csdn.net/weixin_46408961/article/details/121064061
- 链接标题:Scala_Spark中aggregate用法以及结果分析_aggregation如何获取value值-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:1838
文章浏览阅读5.2k次。只做记录,部分结果在代码注释部分:aggregate():是一个聚合函数,接受多个输入,并按照一定的规则运算以后输出一个结果值getNumPartitions:获取RDD的分区数foreachPartition():遍历分区中的元素,参数为函数,如下参数为foreach函数,foreach函数中再使用匿名函数 : x=>print(x.toString()+",")此处foreach中匿名函数相当于python中的如下用法:package spark_rddim._aggregation如何获取value值
版权声明:本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除