下面是Pair RDD的API讲解
转化操作 reduceByKey:合并具有相同键的值; groupByKey:对具有相同键的值进行分组; keys:返回一个仅包含键值的RDD; values:返回一个仅包含值的RDD; sortByKey:返回一个根据键值排序的RDD; flatMapValues:针对Pair RDD中的每个值应用一个返回迭代器的函数,然后对返回的每个元素都生成一个对应原键的键值对记录; mapValues:对Pair RDD里每一个值应用一个函数,但是不会对键值进行操作; combineByKey:使用不同的返回类型合并具有相同键的值; subtractByKey:操作的RDD我们命名为RDD1,参数RDD命名为参数RDD,剔除掉RDD1里和参数RDD中键相同的元素; join:对两个RDD进行内连接; rightOuterJoin:对两个RDD进行连接操作,第一个RDD的键必须存在,第二个RDD的键不再第一个RDD里面有那么就会被剔除掉,相同键的值会被合并; leftOuterJoin:对两个RDD进行连接操作,第二个RDD的键必须存在,第一个RDD的键不再第二个RDD里面有那么就会被剔除掉,相同键的值会被合并; cogroup:将两个RDD里相同键的数据分组在一起 转化操作 reduceByKey:合并具有相同