1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
t = db.mr_sort;
t.drop();
t.ensureIndex( { x : 1 } );
t.insert( { x : 1 } );
t.insert( { x : 10 } );
t.insert( { x : 2 } );
t.insert( { x : 9 } );
t.insert( { x : 3 } );
t.insert( { x : 8 } );
t.insert( { x : 4 } );
t.insert( { x : 7 } );
t.insert( { x : 5 } );
t.insert( { x : 6 } );
m = function(){
emit( "a" , this.x );
};
r = function( k , v ){
return Array.sum( v );
};
res = t.mapReduce( m , r , "mr_sort_out " );
x = res.convertToSingleObject();
res.drop();
assert.eq( { "a" : 55 } , x , "A1" );
res = t.mapReduce( m , r , { out : "mr_sort_out" , query : { x : { $lt : 3 } } } );
x = res.convertToSingleObject();
res.drop();
assert.eq( { "a" : 3 } , x , "A2" );
res = t.mapReduce( m , r , { out : "mr_sort_out" , sort : { x : 1 } , limit : 2 } );
x = res.convertToSingleObject();
res.drop();
assert.eq( { "a" : 3 } , x , "A3" );
|
