dwestheide/kontextfrei

Add treeAggregate action

Closed this issue · 0 comments

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?