1-3

reduceByKey,aggregateByKey,combineByKey底層調用的都是combineByKeyWithClassTag aggregate算子 def aggregate[U: Cla ssTag](zeroValue: U)(seqOp: (U, T) => U, combOp: (U, U) => U): U={} zeroValue:初始值 seqOp:局部聚合 con
相關文章
相關標籤/搜索