spark

1）map操作 /** * map(func):返回一个新的分布式数据集，由每个原元素经过func函数转换后组成 * 将原始集合中的每一个元素*7 * map的操作是一个one to one的操作 */ private def mapMethod(sc: SparkContext) = { val list =

>>阅读原文<<