MongoCollection.java 文件源码

public Iterator<BasicDBObject> aggregate(String description, List<DBObject> pipeline) {
  if (log.isDebugEnabled()) {
    log.debug("--"+dbCollection.getName()+"-> "+description+" q="+toString(pipeline));
  }
  AggregationOutput aggregationOutput = dbCollection.aggregate(pipeline);
  return new LoggingIterator(this, aggregationOutput.results().iterator());
}