spark RDD 的map与flatmap区别说明

HDFS到HDFS过程app 看看map 和flatmap的位置分布式 Flatmap 和map 的定义  map()是将函数用于RDD中的每一个元素,将返回值构成新的RDD。函数 flatmap()是将函数应用于RDD中的每一个元素,将返回的迭代器的全部内容构成新的RDDspa 例子:scala val rdd = sc.parallelize(List("coffee panda","happ
相关文章
相关标签/搜索