[学习笔记]
reduce将rdd中元素前两个传给输入函数,产生一个新的return值,将新产生的return值与rdd中下一个元素(即第三个元素)组成两个元素,再被传给输入函数,这样递归运作,直到最后只有一个值为止。*/
val rdd07 = sc.parallelize(1 to 10)
val sum = rdd07.reduce((x, y) => x + y)
println("sum is " + sum)
文章转载自原文:
如对本文有疑问, 点击进行留言回复!!
HBase Filter 过滤器之FamilyFilter详解
去 HBase,Kylin on Parquet 性能表现如何?
如何找到Hive提交的SQL相对应的Yarn程序的applicationId
网友评论