创建KeyValue对RDDs

使用函数map,返回keyvalue对

例如,包含数行数据的RDD,那每行的第一个单词作为keys。

sparl.txt中的内容如下:

hello !

hello world

hello spark

val rdd = sc.textFile("spark.txt")
val rdd2 = rdd.map(line=>(line.split(" ")(0),line))

常见的操作:

KeyValue对RDDs-LMLPHP

KeyValue对RDDs-LMLPHP

05-11 22:49