ProcessingWorker.java 文件源码

public Iterable<DBObject> getAggregationQuery(String key, int min, int max) {
    DBObject match = new BasicDBObject(key, new BasicDBObject("$gt", min).append("$lt", max));
    DBObject matchOp = new BasicDBObject("$match", match);
    DBCollection fullData = mc.getCollection(type);
    DBObject groupOp = setupGroupOperation();
    AggregationOutput ao = fullData.aggregate(matchOp, groupOp);
    return ao.results();
}