大数据二

combineByKey 函数通过以下三个函数参数实现reduceByKey。 createCombiner() --用于产生累加器键的初值。比如lambda x: (x, 1))。这里x指的是分数值 mergeValue() --每移动一条记录设置当前的累加器的值。比如：(lambda x, y: (x[0] + y, x[1] + 1)), mergeCombiners() --在每一键组内累

>>阅读原文<<