summaryrefslogtreecommitdiff
path: root/jstests/mr_index.js
blob: 521d44d29f067a70e64c7d08cc5587ce6be2d79b (plain)
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

t = db.mr_index
t.drop()

outName = "mr_index_out"
out = db[outName]
out.drop()

t.insert( { tags : [ 1  ] } )
t.insert( { tags : [ 1 , 2  ] } )
t.insert( { tags : [ 1 , 2 , 3 ] } )
t.insert( { tags : [ 3 ] } )
t.insert( { tags : [ 2 , 3 ] } )
t.insert( { tags : [ 2 , 3 ] } )
t.insert( { tags : [ 1 , 2 ] } )

m = function(){ 
    for ( i=0; i<this.tags.length; i++ )
        emit( this.tags[i] , 1 );
}

r = function( k , vs ){
    return Array.sum( vs );
}

ex = function(){
    return out.find().sort( { value : 1 } ).explain()
}

res = t.mapReduce(  m , r , { out : outName } )
    
assert.eq( "BasicCursor" , ex().cursor , "A1" )
out.ensureIndex( { value : 1 } )
assert.eq( "BtreeCursor value_1" , ex().cursor , "A2" )
assert.eq( 3 , ex().n , "A3" )

res = t.mapReduce(  m , r , { out : outName } )
    
assert.eq( "BtreeCursor value_1" , ex().cursor , "B1" )
assert.eq( 3 , ex().n , "B2" )
res.drop()