Spark Transformation和Action算子速查表

Transformation算子 Transformation算子 做用 map(func) 返回一個新的分佈式數據集,其中每一個元素都是由源RDD中每個元素通過func函數轉換獲得的 filter(func) 返回一個新的數據集,其中包含的元素來自源RDD中元素通過func函數過濾後的結果(func函數返回true的結果) flatMap(func) 相似於map, 可是每一個元素能夠映射到0到
相關文章
相關標籤/搜索