i would maybe look at a map/reduce it may make more sense for your situation to do something like that in a map phase and group them up and then process in reduce phase