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文件系统

>>阅读原文<<