Как установить allowDiskUse: true весной mongoTemplate

Question

В настоящее время я использую mongoDB весной как mongoTemplate.

public List<BasicDBObject> getMoviesByName() { 
    Aggregation aggregation = newAggregation(unwind("movies"), 
      match(where("movies.language").is("english")), 
      sort(Sort.Direction.DESC, "createDate"), 
      group(fields().and("_id", "$_id").and("category", "$category")).push("$movies").as("movies"), 
      project(fields().and("category", "$category").and("movies", "$movies")).andExclude("_id")); 
    AggregationResults<BasicDBObject> groupResults = mongoTemplate.aggregate(
      aggregation, "movieCollection", BasicDBObject.class); 
    return groupResults.getMappedResults(); 
} 

я получаю исключение

com.mongodb.CommandFailureException: { "serverUsed" : "XXX.XXX.XX.XX:27017" , "errmsg" : "exception: Sort exceeded memory limit of 104857600 bytes, but did not opt in to external sorting. Aborting operation. Pass allowDiskUse:true to opt in." , "code" : 16819 , "ok" : 0.0} 

Я изучил некоторые сообщения allowDiskUse: ИСТИНА решение, я попытался установить так, но никакого результата не .please сказать мне, как установить на приведенный выше код

Answer 1

Вы можете сделать, как показано ниже.

MongoClient client = new MongoClient(new ServerAddress("127.0.0.1", 27017)); 

DB test = client.getDB("test"); 

DBCollection sample = test.getCollection("sample"); 

List<DBObject> aggregationQuery = Arrays.<DBObject>asList(
     new BasicDBObject("$sort",new BasicDBObject("score",-1)), 
     new BasicDBObject("$limit",1) 
); 

System.out.println(aggregationQuery); 

Cursor aggregateOutput = sample.aggregate(
     aggregationQuery, 
     AggregationOptions.builder() 
       .allowDiskUse(true) 
       .build() 
); 

//rest of the code 

или просто

Aggregation aggregation = newAggregation(…). 
     withOptions(newAggregationOptions(). 
     allowDiskUse(true).build()); 

Answer 2

Вы можете установить параметры агрегации как

Aggregation aggregation = newAggregation(…).withOptions(Aggregation.newAggregationOptions(). 
         allowDiskUse(true).build());