【Spark學習筆記】KeyValue對RDDs

創建KeyValue對RDDs:使用map()函數,返回key/value對 例如,包含數行數據的RDD,把每行數據的第一個單詞作爲keys val rdd2=rdd.map(line=>(line.split(" ")(0),line)) image.png val rdd3=sc.parallelize(Array((1,2),(3,4),(3,6))) (1,2) (3,4) (3,6) v
相關文章
相關標籤/搜索