日期:2014-05-16 浏览次数:20531 次
String map = "function() { emit(this.offer_price, {count:1});}";
        String reduce = "function(key, values) {";
        reduce = reduce + "var total = 0;";
        reduce = reduce + "for(var i=0;i<values.length;i++){total += values[i].count;}";
        reduce = reduce + "return {count:total};}";
        String result = "resultCollection";
        MapReduceOutput mapReduceOutput = coll.mapReduce(map, reduce.toString(), result, null);
        DBCollection resultColl = mapReduceOutput.getOutputCollection();
        DBCursor cursor = resultColl.find();
        while (cursor.hasNext()) {
            System.out.println(cursor.next());
        }
options.socketTimeout = 2000;
 public DBPort get(){
        DBPort port = null;
        if ( ! _waitingSem.tryAcquire() )
            throw new SemaphoresOut();
 MongoOptions options = m.getMongoOptions();
            options.autoConnectRetry = true;
            options.connectionsPerHost = 500;
            options.maxWaitTime = 5000;
            options.socketTimeout = 0;
            options.connectTimeout = 15000;
            options.threadsAllowedToBlockForConnectionMultiplier = 4;MongoOptions options = new MongoOptions();
            options.autoConnectRetry = true;
            options.connectionsPerHost = 1000;
            options.maxWaitTime = 5000;
            options.socketTimeout = 0;
            options.connectTimeout = 15000;
            options.threadsAllowedToBlockForConnectionMultiplier = 5000;
            m = new Mongo(new ServerAddress("10.20.141.22", 28018), options);