【Spark学习笔记】Scala基础（二）之Aciton介绍

Action介绍 在RDD上计算出来一个结果，把结果返回给driver program或保存在文件系统，例如：count()，save 常用action reduce() 接收一个函数，作用在RDD两个类型相同的元素上，返回新元素。 可以实现，RDD中元素的累加，计数和其他类型的聚集操作。 val rdd=sc.parallelize(Array(1,2,3,3)) rdd.reduce((x,y

>>阅读原文<<