KeyValue对RDDs

创建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))

常见的操作:

原文地址:https://www.cnblogs.com/twodoge/p/10016144.html