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

>>阅读原文<<