1. 程式人生 > >KeyValue對RDDs

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

常見的操作: