➢ 函数签名 def countByKey(): Map[K, Long] ➢ 函数说明 //统计每种 key 的个数 val rdd: RDD[(Int, String)] = sc.makeRDD(List((1, "a"), (1, "a"), (1, "a"), (2, "b"), (3, "c"), (3, "c"))) // 统计每种 key 的个数 val result: collection.Map[Int, Long] = rdd.countByKey()