Spark的reduceByKey和reduce

reduce的操做對象是列表。對象 如rdd={1,2,3,3} rdd.reduce((x,y)=> x+y)獲得結果是:9 reduceByKey()的操做對象是元組。 如 rdd1={('panda',3),('pink',4)},rdd2={('panda',(3,2)),('pink',(4,3))} rdd.reduceByKey((x,y)=>x+y)獲得結果{('panda',7)
相關文章
相關標籤/搜索