Mongodb에서의 MapReduce

MapReduce 기본 개념

mongoDB에서 MR 사용법

db.collection명.mapReduce(map함수,reduce함수,...)

---

1. map 정의

- emit() 이라는 함수를 이용해서 reduce 쪽으로 내보내는 작업 수행

- key와 value를 내보내기

var map = function(){ emit(this.dept,this.servlet) }

---

2. reduce 정의

- map() 함수에서 emit 시킨 key와 value가 매개변수로 전달되면 원하는 형태로 가공

var reduce = function(key,values){ return Array.sum(values) }

---

3. mapReduce 정의

db.score.mapReduce(map,reduce,{out:"add_total"})

---

4. 결과화면

{ "result" : "add_total", "timeMillis" : 31187.0000000000000000, "counts" : { "input" : 14, "emit" : 14, "reduce" : 5, "output" : 5 }, "ok" : 1.0000000000000000, "_o" : { "result" : "add_total", "timeMillis" : 31187, "counts" : { "input" : 14, "emit" : 14, "reduce" : 5, "output" : 5 }, "ok" : 1.0000000000000000 }, "_keys" : [ "result", "timeMillis", "counts", "ok" ], "_db" : { "_mongo" : "connection to localhost:27017{ SSL: { sslSupport: false, sslPEMKeyFile: \"\" } } { SSH: { host: \"\", port: 22, user: \"\", password: \"\", publicKey: { publicKey: \"\", privateKey: \"\", passphrase: \"\" }, currentMethod: 0 } }", "_name" : "mini", "score" : "mini.score" }, "_coll" : "mini.add_total" }

---

5. MR된 결과 확인

db.dept_total.find()

제목 넣기

ㄴㅇㄹㅇㄴㄹ

---