Spark2.3.2源碼解析： 算子解析 [ 二 . Value數據類型的Transformation算子 ]

  本文講述的是[   Value數據類型的Transformation算子   ] 分類的算子.    一、輸入分區與輸出分區一對一型   　　　　1、map算子   將原來 RDD 的每個數據項通過 map 中的用戶自定義函數 f 映射轉變爲一個新的元素。源碼中 map 算子相當於初始化一個 RDD， 新 RDD 叫做 MappedRDD(this, sc.clean(f))。   圖 1中每

>>阅读原文<<