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中的每個

>>阅读原文<<