MongoDB--MapReduce分布统计s

Posted 2020-09-24

MapReduce

Mapreduce：要操作的目标集合
Map：映射函数（生成键值对序列，作为reduce函数参数） //传入分组的key和需要统计的值
Reduce：统计函数 //格式化返回的参数对象
Query：目标记录过滤 //在mp之前对查询过滤条件
Sort：目标记录排序
Limit：限制目标记录数量
Out：统计结果存放集合（不指定使用临时集合，在客户端断开后自动删除）// 将结果输出到某张表内
Keeptemp：是否保留临时集合
Finalize：最终处理函数（对reduce返回结果进行最终整理后存入结果集合） //对结果进行处理
Scope：向map、reduce、finalize导入外部变量

Verbose：显示详细的时间统计信息。

数据结构：

 

db.runCommand({
		mapreduce:"students",
		map:function(){
			emit(this.classid,this.name); 
		},
		reduce:function(key,values){
			var res={classid:key,names:values} 
			return res;
		},
		query:{"age":{"$gt":10}}, 
		finalize:function(key,reducevalues){
			var obj={};
			obj.keyname=key;
			obj.values=reducevalues.names;
			return obj;
		},
		out:"test_mp2" 
	})

 

 

db.runCommand({
		mapreduce:"students",
		map:function(){
			emit(this.classid,this.name); 
		},
		reduce:function(key,values){
			return values.length;
		},
		query:{"age":{"$gt":10}},
		out:"test_mp2" 
	})

针对第二个统计步骤为：