Map reduce with mongodb

0

Trying to run a map reduce on a mongodb collection. Using iReport to design/test the report.

The problem is:

I specify "findQuery" to filter out the rows/documents I want to run map reduce on. Then I use mapReduce to specify map, reduce and out.

But the map reduce is run on all rows/documents in the collection, and then "findQuery" is applied on result of map reduce.

Following is the complete query that I have written in the edit query dialog box in iReport.

 

{
 collectionName: "packages",
 findQuery: {"cs.ss": "RTO"},
 sort: {'cn': 1},
 mapReduce: {
  'map': 'function () {
            var p1 = 0; var p2 = 0; var p3 = 0; var p4 = 0;
            var diff = Math.ceil((ISODate().getTime()+330*60*1000-this.pd.getTime())/(1000*60*60*24));
            if (diff == 1){
                p1 = 1;
            }else{
                if (diff == 2){
                  p2 = 1;
                }else{
                  if (diff == 3){
                      p3 = 1;
                  }else{
                      p4 = 1;
                  }
                }
            }
            var cn = String(this.cn);
            emit({cn: cn}, {p1: p1, p2: p2, p3: p3, p4: p4});
        }',
  'reduce': 'function (key, values){
              var result = {p1: 0, p2: 0, p3: 0, p4: 0};
              values.forEach(function (v){
                  result.p1 += parseInt(v.p1);
                  result.p2 += parseInt(v.p2);
                  result.p3 += parseInt(v.p3);
                  result.p4 += parseInt(v.p4);
              });
              return result;
           }',
  'out': 'cn_wise_pendency',
 },
}
kanishkdewan's picture
Joined: Dec 11 2013 - 9:12pm
Last seen: 4 years 1 month ago

0 Answers:

No answers yet
Feedback
randomness