Add the `aggregate` action
Closed this issue · 0 comments
dwestheide commented
Add the aggregate method as defined on RDD to DCollectionOps:
def aggregate[U: ClassTag](zeroValue: U)(seqOp: (U, T) => U, combOp: (U, U) => U): U
Closed this issue · 0 comments
Add the aggregate method as defined on RDD to DCollectionOps:
def aggregate[U: ClassTag](zeroValue: U)(seqOp: (U, T) => U, combOp: (U, U) => U): U