spark transformation和action算子

spark transformation和action的算子 map(func) 返回一個新的分佈式數據集,由每一個原元素通過func函數處理後的新元素組成 filter(func) 返回一個新的數據集,由通過func函數處理後返回值爲true的原元素組成 flatMap(func) 相似於map,可是每個輸入元素,會被映射爲0個或多個輸出元素,(所以,func函數的返回值是一個seq,而不是單一
相關文章
相關標籤/搜索