有一个mongodb集合a,另一个文件是文本文件,现在我想用mapreduce读取文本文件,测试a中是否有每条记录,如果有,根据文本文件中相应的记录更新a中的记录,或者将记录插入a中。现在我用mongoupdatewritable类来做这件事,但是它太慢了,有人能告诉我如何提高做这件事的速度吗?
代码示例如下:
query.append("x", x);
update.append("$set", appendObj.append("y", y));
muw.setQuery(record);
muw.setModifiers(update);
context.write(NullWritable.get(), muw);
job3.setMapOutputValueClass(MongoUpdateWritable.class);
job3.setOutputFormatClass(MongoOutputFormat.class);
暂无答案!
目前还没有任何答案,快来回答吧!