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