1. map(func) 将func函数作用到数据集的每个元素，生成一个新的分布式的数据集并返回 2. filter(func) 选出所有func返回值为true的元素，作为一个 ...

Spark相比于Mapreduce的一大优势就是提供了很多的方法，可以直接使用；另一个优势就是执行速度快，这要得益于DAG的调度，想要理解这个调度规则，还要理解函数之间的依赖关系。 本篇就 ...