大數據二

combineByKey 函數通過以下三個函數參數實現reduceByKey。 createCombiner() --用於產生累加器鍵的初值。比如lambda x: (x, 1))。這裏x指的是分數值 mergeValue() --每移動一條記錄設置當前的累加器的值。比如：(lambda x, y: (x[0] + y, x[1] + 1)), mergeCombiners() --在每一鍵組內累

>>阅读原文<<