Add treeAggregate action
Closed this issue · 0 comments
dwestheide commented
Add the treeAggregate
method to DCollectionOps
, as defined on RDD
:
def treeAggregate[U: ClassTag](zeroValue: U)( seqOp: (U, T) => U, combOp: (U, U) => U, depth: Int = 2): U
It seems that the behaviour should be the same as for aggregate
?