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