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)
相关文章
相关标签/搜索