Я использую следующий mongodb java драйвер
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-sync</artifactId>
<version>3.9.1</version>
</dependency>
Большинство функций работают как (создание / удаление коллекции, вставка записей) и т. Д., Но mapreduce не работает должным образом.Также я вижу, что большинство классов устарели, связанные с mapreduce, но в javadoc не упоминается альтернативный класс.
Вот способ, которым я пытался выполнить запрос mapreduce
MapReduceIterable<Document> mapReduceIterable = mongoDatabase.getCollection(inputCollectionName).mapReduce(mapFunction, reduceFunction);
mapReduceIterable.action(MapReduceAction.REPLACE);
mapReduceIterable.collectionName("keyword_merged_temp");
mapReduceIterable.bypassDocumentValidation(true);
mapReduceIterable.jsMode(true);
mapReduceIterable.nonAtomic(false);
mapReduceIterable.limit(100);
mapReduceIterable.iterator();
Не уверен, что этоэто способ записи для выполнения mapreduce.У них есть другой драйвер Java с именем
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-reactivestreams</artifactId>
<version>1.10.0</version>
</dependency>
Даже с этой же проблемой.Карта Уменьшить запросы не работают.