鍵值對RDD(Pair RDD )

1:map函數把一個普通的RDD轉化爲pair RDD var lines = sc.parallelize(List("i love you")) val pairs = lines.map(x=>(x,1)) pairs.foreach(println) (i love you,1)分佈式 2:Pai RDDr的轉化操做 因爲pair RDD中包含二元組,因此須要傳遞函數應當操做二元組而不是獨
相關文章
相關標籤/搜索