java - MongoDB:使用 java 驱动程序 3.0.x 执行 mapreduce 和过滤

Question

我正在使用 java 驱动程序 3.0.1 开发一个 java 小项目和 mongoDB。需要执行一个 MapReduce 算法，在 map 函数之前，执行一个查询以减少数据并提高性能。

我见过 api 驱动程序并存在类 MongoCollection 和方法 mapReduce 但仅以 map 和 reduce 函数作为参数。它没有任何查询参数。

dbConnection.getCollection("test").mapReduce(mapFunction, reduceFunction)

在旧的 API 中，有 MapReduceCommand 可以做到这一点

MapReduceCommand cmd = new MapReduceCommand("test", map, reduce, null, MapReduceCommand.OutputType.INLINE, query)

有什么建议吗？

谢谢大家!

Answer 1

mapReduce MongoCollection 上的方法返回 MapReduceIterable 的一个实例，它有一个 filter查询过滤器在执行映射阶段之前应用于集合的方法。它看起来像这样:

dbConnection.getCollection("test").mapReduce(mapFunction, reduceFunction)
                                  .filter(queryFilter)