共 4 篇文章 |
|
In [12]: for k in db[res["result"]].find(): print k ....:{u''_id'': 2.0, u''value'': 1.0}{u''_id'': 3.0, u''value'': 1.0}{u''_id'': 4.0, u''value'': 1.0}{u''_id'': 5.0, u''value''... 阅367 转2 评0 公众公开 11-09-06 16:25 |
阅355 转2 评0 公众公开 11-09-06 16:19 |
基于MongoDB MapReduce的统计分析基于MongoDB MapReduce的统计分析2010-12-10 10:04.执行java 代码DBObject query = newBasicDBObject(); query.put("userid", userid); query.put("date", newBasicDBObject("$gte", fromDate)); *.getCollection().mapReduce(mapfun, reducefun,"pageview_results&q... 阅1221 转5 评0 公众公开 11-09-06 16:17 |
我现在使用的方法就是mongodb的MapReduce功能,其实这个需求也可以认为是个group操作,而mongodb的group功能就是基于MapReduce的,但group对结果集的大小是有限制的。runCommand( { mapreduce : <collection>, map : <mapfunction>, reduce : <reducefunction> [, query : <query filter object>] [, sort : <sort ... 阅1159 转2 评0 公众公开 11-07-11 05:08 |