键值对RDD有哪些？combineByKey算子如何使用？

对于你的第一个问题：键值对RDD有三种类型，分别是PairRDD、DoubleRDD和CoGroupedRDD。

在使用combineByKey算子时，需要指定三个函数参数，分别是：

1. createCombiner函数，创建一个初始的累加值。
2. mergeValue函数，将输入数据和累加值进行合并。
3. mergeCombiners函数，将不同分区的累加值进行合并。

举例说明，假设有一个包含年龄和姓名的键值对RDD：

val data = sc.parallelize(Seq(("Alice", 25), ("Bob", 30), ("Charlie", 20), ("David", 25), ("Eric", 30)))

我们想要对这个RDD按年龄进行分组，并计算每个年龄段的人数和年龄总和，可以使用combineByKey如下：

val comb = data.combineByKey(
  (v) => (1, v), // 初始累加值为(1, v)
  (acc: (Int, Int), v) => (acc._1 + 1, acc._2 + v), // 合并操作，将人数和年龄进行加和
  (acc1: (Int, Int), acc2: (Int, Int)) => (acc1._1 + acc2._1, acc1._2 + acc2._2) // 对不同分区的累加值进行合并
)

这样得到的comb RDD，每个键就是年龄，每个值就是一个元组，包含该年龄段的人数和年龄总和。