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
相關文章
相關標籤/搜索