spark

1）map操作 /** * map(func):返回一個新的分佈式數據集，由每個原元素經過func函數轉換後組成 * 將原始集合中的每一個元素*7 * map的操作是一個one to one的操作 */ private def mapMethod(sc: SparkContext) = { val list =

>>阅读原文<<