Spark基礎腳本入門實踐2:基礎開發

  1、最基本的Map用法 val data = Array(1, 2, 3, 4, 5) val distData = sc.parallelize(data) val result = distData.map(x=>x*x) println(result.collect().mkString(",")) 其中最關鍵的操作就是：從分佈式數據集 --轉換--> 並行數據集 from a dist

>>阅读原文<<