Spark经常使用算子总结

Spark经常使用算子总结 // Transformation算子 一、map算子 接收一个函数，对于RDD中的每个元素执行此函数操做，结果做为返回值。 val rdd = sc.parallelize(Array(1, 2, 3, 4), 1) rdd.map(x => x*x).foreach(println) // 1 4 9 16node 二、filter 接收一个函数，对于RDD中的每个

>>阅读原文<<