特牛生活网

flatmap和map的区别_map和flatmap先用那个-CSDN博客

网友收藏
文章浏览阅读1.5w次。map()是将函数用于RDD中的每个元素,将返回值构成新的RDD。flatmap()是将函数应用于RDD中的每个元素,将返回的迭代器的所有内容构成新的RDD,这样就得到了一个由各列表中的元素组成的RDD,而不是一个列表组成的RDD。有些拗口,看看例子就明白了。val rdd = sc.parallelize(List("coffee panda","happy panda","_map和flatmap先用那个