Spark算子：键值RDD转换操作(1)–mapValues、flatMapValues_rdd mapvalues

mapValues（对value进行一对一的映射）

def mapValues[U](f: (V) => U): RDD[(K, U)]

同基本转换操作中的map，只不过mapValues是针对[K,V]中的V值进行map操作。

例二：

val rdd3=sc.parallelize(List((1,2),(3,4)))
rdd3.mapValues(_.to(5)).collect().foreach(println(_))

结果：

(1,Range(2, 3, 4, 5))
(3,Range(4, 5))

flatMapValues（会先对values进行map的操作，再进行一对多的压平）

def flatMapValues[U](f: (V) => TraversableOnce[U]): RDD[(K, U)]

同基本转换操作中的flatMap，只不过flatMapValues是针对[K,V]中的V值进行flatMap操作。

例二：把一个元组映射成多个元组

val rdd3=sc.parallelize(List((1,2),(3,4)))
rdd3.flatMapValues(_.to(5)).collect().foreach(println(_))

结果：

(1,2)
(1,3)
(1,4)
(1,5)
(3,4)
(3,5)