spark core開發2

spark中常用的算子: map算子: 將原來RDD的每個數據項通過map中的用戶自定義函數f映射轉變爲一個新的元素,途中每個方框表示一個RDD分區,左側的分區經過用戶自定義函數f 映射爲右側的新RDD分區,但是,實際只有等到action算子觸發後,這個f函數纔會和其他函數在一個stage中的數據進行運算 mapValues算子: 針對(key,value)型數據中的value進行map操作 而不
相關文章
相關標籤/搜索