网站介绍：文章浏览阅读205次。1.keys算子理解:只能针对对偶元组使用,keys这个方法是定义在PariPDDfunction中,只有Rdd中装的是对偶元组才能将rdd转换为PariRDDFunction(隐式转换)一般我们经常使用的reduceBykey或者是groupBykey 这种带有Bykey操作的算子都是先将RDD(对偶元组)通过隐式转换为PariRDDFunction 才能调用算子keys算子底层 调用的是map方法,是对rdd中的每一个分区调用map方法2.values算子理解:只能针对对偶元组使用,valu._sparkcore init
- 链接地址：https://blog.csdn.net/Fresh_man888/article/details/110356164
- 链接标题：Spark-Core之源码级算子详解(二)_sparkcore init-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：5700
- 网站标签：sparkcore init
