Mapreduce

我在做MR的时候想把结果写入一个新集合中,其实之前也有做过,但是在我印象中好像总是写不进去啊,摔!

//....more code try { cmd = new MapReduceCommand( this.dbc, MapString, ReduceString, dbtemp, MapReduceCommand.OutputType.REPLACE, query); cmd.setFinalize(Finalize); output = this.dbc.mapReduce(cmd); } //...more code

MapReduceCommand 的形参如下

public MapReduceCommand(com.mongodb.DBCollection inputCollection, java.lang.String map, java.lang.String reduce, java.lang.String outputCollection, com.mongodb.MapReduceCommand.OutputType type, com.mongodb.DBObject query) { /* compiled code */ }

希望有做过mongo的小伙伴一起讨论讨论