首页 > TAG信息列表 > CompactBuffer
键值对类型转换算子
1. groupByKey 定义：groupByKey([numPartitions])、 解释：只对键值对类型RDD生效，同时返回的是一个新的RDD[(key,Iterator[Value])] 案例： def groupByKeyOper(sc: SparkContext): Unit = { println("----------------groupByKey开始------------------") val rdd = sc.textFile