MapReduce

Map

쿼리한 결과를 reduce할 수 있게 데이터를 모으는 역할

 

Reduce

모아진 결과를 집계하는 역할

 

emit(key, value) 

reduce의 key와 value로 들어간다.

 

out

결과로 나온 데이터를 임시로 저장하는 collection

out : "order_totals" -> 나온 결과를 rder_totals에 임시로 저장하겠다.

 

 

 

// 데이터 넣는 부분
 
var cust = {};
cust.cust_id = "A123"
cust.amount = 500;
cust.status = "A";
 
cust.cust_id = "A123"
cust.amount = 250;
cust.status = "A";
 
cust.cust_id = "B212"
cust.amount = 200;
cust.status = "A";
 
cust.cust_id = "A123"
cust.amount = 300;
cust.status = "D";
 
db.test3.insert(cust);
db.test3.find();
 
 
 
// mapReduce하는 부분
db.test3.mapReduce(
 
    function(){emit(this.cust_id, this.amount)},
 
     // Array.sum(value) -> value를 모두 더하겠다.
     // 값은 order_totals로 들어감 
    function(key, value){return Array.sum(value)},
    {
        query : {status : "A"},
        out : "order_totals"
    } 
 
);
 
// 결과 값 보기.
db.order_totals.find();
 
 
// 결과 창
 
/* 1 */
{
    "_id" : "A123",
    "value" : 750.0000000000000000
}
 
/* 2 */
{
    "_id" : "B212",
    "value" : 200.0000000000000000
}