mesos/spark — Issue #97: Add foldByKey and aggregateByKey
Author: mateiz
Created: 2011-11-30 19:40:09+00:00
State: open

Similar to the new fold() and aggregate() methods in #95, we should have foldByKey and aggregateByKey for pair RDDs. The main thing that makes this slightly harder is that we'll have to change the combineByKey API and ShuffledRDD to allow taking in a "zero value".