spark RDD 的map与flatmap区别说明

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