Spark行動算子中的reduce()聚合|collect()以數組的形式返回數據集|foreach(f)遍歷RDD中每一個元素

行動算子是觸發了整個作業的執行。因爲轉換算子都是懶加載，並不會立即執行。 reduce() 1）函數簽名：def reduce(f: (T, T) => T): T 2）功能說明：f函數聚集RDD中的所有元素，先聚合分區內數據，再聚合分區間數據。 代碼實現 collect() 1）函數簽名：def collect(): Array[T] 2）功能說明：在驅動程序中，以數組Array的形式返回數據集

>>阅读原文<<