Spark行爲算子中的aggregate()|fold()|countByKey()統計每種key的個數|save相關算子

aggregate() 代碼實現 fold() 代碼實現 countByKey()統計每種key的個數 1）函數簽名：def countByKey(): Map[K, Long] 2）功能說明：統計每種key的個數 代碼實現 save相關算子 1）saveAsTextFile(path)保存成Text文件 （1）函數簽名 （2）功能說明：將數據集的元素以textfile的形式保存到HDFS文件系統

>>阅读原文<<