Create a helper function for the aggregation framework on the DBCollection class. The signature should be something like:

public AggregationOutput aggregate(DBObject ... ops)

AggregationOutput should follow the conventions of MapReduceOutput, and there should probably be a base class extracted.