当前位置:   article > 正文

MapReduce统计

mapreduce统计

MongoDB 上使用 Map/Reduce进行并行"统计"很容易。
使用 MapReduce 要实现两个函数 Map 函数和 Reduce 函数,Map 函数调用 emit(key, value),
遍历 collection 中所有的记录, 将key 与 value 传递给 Reduce 函数进行处理。
Map函数和Reduce函数可以使用 JavaScript 来实现,可以通过 db.runCommand 或 mapReduce 命令来执行一个MapReduce 的操作:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
db.runCommand(
{
     mapReduce: <collection>,
     map: < function >,
     reduce: < function >,
     out: <output>,
     query: <document>,
     sort : <document>,
     limit: <number>,
     finalize: < function >,
     scope: <document>,
     jsMode: <boolean>,
     verbose: <boolean>
})

参数说明:
mapreduce: 要操作的目标集合。

map: 映射函数 (生成键值对序列,作为 reduce 函数参数)。

reduce: 统计函数。

out: 统计结果存放集合 (不指定则使用临时集合,在客户端断开后自动删除)。

query: 目标记录过滤

sort: 目标记录排序。

limit: 限制目标记录数量。

finalize: 最终处理函数 (对 reduce 返回结果进行最终整理后存入结果集合)

scope: 向 map、reduce、finalize 导入外部变量。

jsMode: 是否转换Bson格式在map和reduce执行间

verbose: 显示详细的时间统计信息。


下面我们来搞一个例子吧:

准备一些数据:

135332174.png

接下来我们演示如何统计各个班的学生数量

Map:

Map 函数必须调用 emit(key, value) 返回键值对,使用 this 访问当前待处理的 Document。

1
2
3
m =  function (){
     emit(this.classid,1);
}

value 可以使用 JSON Object 传递 (支持多个属性值)。

例如:emit(this.classid, {count:1})
Reduce:

Reduce 函数接收的参数类似 Group 效果,将 Map 返回的键值序列组合成 { key, [value1,
value2, value3, value...] } 传递给 reduce。

1
2
3
4
5
r =  function (key,values){
     var x = 0;
     values.forEach( function ( v ){x +=  v });
     return  x;
}

Reduce 函数对这些 values 进行 "统计" 操作,返回结果可以使用 JSON Object。

Result:

140428607.png

mapReduce() 将结果存储在 "students_res" 表中。
140552995.png

Finalize:

利用 finalize() 我们可以对 reduce() 的结果做进一步处理。

1
2
3
f =  function (key,value){
     return  {classid:key,count:value}
}

我们再重新计算一次,看看结果:

141023438.png


Options:

我们还可以添加更多的控制细节。

1
2
3
4
5
6
7
8
db.runCommand({
     mapreduce: "stu" ,
     map:m,
     reduce:r,
     out: "stu_res" ,
     finalize:f,
     query:{age:{$gt:10}}
});

144409503.png


可以看到先进行了过滤,只取 age>10 的数据,然后再进行统计,所以就没有 age=9 的数
据了。


本文出自 “phper-每天一点点~” 博客,请务必保留此出处http://janephp.blog.51cto.com/4439680/1323812

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/你好赵伟/article/detail/781100
推荐阅读
相关标签
  

闽ICP备14008679号