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
45
46
47
48
49
50
51
|
t = db.mr_errorhandling;
t.drop();
t.save( { a : [ 1 , 2 , 3 ] } )
t.save( { a : [ 2 , 3 , 4 ] } )
m_good = function(){
for ( var i=0; i<this.a.length; i++ ){
emit( this.a[i] , 1 );
}
}
m_bad = function(){
for ( var i=0; i<this.a.length; i++ ){
emit( this.a[i] );
}
}
r = function( k , v ){
var total = 0;
for ( var i=0; i<v.length; i++ )
total += v[i];
return total;
}
res = t.mapReduce( m_good , r , "mr_errorhandling_out" );
assert.eq( { 1 : 1 , 2 : 2 , 3 : 2 , 4 : 1 } , res.convertToSingleObject() , "A" );
res.drop()
res = null;
theerror = null;
try {
res = t.mapReduce( m_bad , r , "mr_errorhandling_out" );
}
catch ( e ){
theerror = e.toString();
}
assert.isnull( res , "B1" );
assert( theerror , "B2" );
assert( theerror.indexOf( "emit" ) >= 0 , "B3" );
// test things are still in an ok state
res = t.mapReduce( m_good , r , "mr_errorhandling_out" );
assert.eq( { 1 : 1 , 2 : 2 , 3 : 2 , 4 : 1 } , res.convertToSingleObject() , "A" );
res.drop()
assert.throws( function(){ t.mapReduce( m_good , r , { out : "xxx" , query : "foo" } ); } )
printjson( t.mapReduce( function(){ emit( 1 , db.foo.findOne() ); } , r , { out : { inline : true } } ) )
|
