summaryrefslogtreecommitdiff
path: root/jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js')
-rw-r--r--jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js19
1 files changed, 11 insertions, 8 deletions
diff --git a/jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js b/jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js
index 857c18c297c..589e072b631 100644
--- a/jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js
+++ b/jstests/noPassthroughWithMongod/mapreduce_intermediate_reduce.js
@@ -2,8 +2,7 @@
// in-memory state small. See SERVER-12949 for more details.
//
function assertGLEOK(status) {
- assert(status.ok && status.err === null,
- "Expected OK status object; found " + tojson(status));
+ assert(status.ok && status.err === null, "Expected OK status object; found " + tojson(status));
}
var db = db.getSisterDB("MapReduceTestDB");
@@ -18,16 +17,20 @@ var expectedOutColl = [];
var bulk = coll.initializeUnorderedBulkOp();
for (var i = 0; i < 10; i++) {
for (var j = 1; j < 50; j++) {
- bulk.insert({ idx: i, j: j });
+ bulk.insert({idx: i, j: j});
}
- expectedOutColl.push ({ _id: i, value: j - 1 });
+ expectedOutColl.push({_id: i, value: j - 1});
}
assert.writeOK(bulk.execute());
-function mapFn() { emit(this.idx, 1); }
-function reduceFn(key, values) { return Array.sum(values); }
+function mapFn() {
+ emit(this.idx, 1);
+}
+function reduceFn(key, values) {
+ return Array.sum(values);
+}
-var out = coll.mapReduce(mapFn, reduceFn, { out: { replace: "mrOutput" } });
+var out = coll.mapReduce(mapFn, reduceFn, {out: {replace: "mrOutput"}});
// Check the output is as expected
//
@@ -38,7 +41,7 @@ assert.eq(out.counts.input, 490, "input count is wrong");
assert.eq(out.counts.emit, 490, "emit count is wrong");
// If this fails, most probably some of the configuration settings under mongo::mr::Config have
-// changed, such as reduceTriggerRatio or maxInMemSize. If not the case, then something else
+// changed, such as reduceTriggerRatio or maxInMemSize. If not the case, then something else
// must have changed with when intermediate reduces occur (see mongo::mr::State::checkSize).
//
assert.eq(out.counts.reduce, 14, "reduce count is wrong");