创建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))
常见的操作:
使用函数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))
常见的操作: