Streamování výsledku agregované operace pomocí spring-data-mongodb

Pro ty, kteří se stále snaží najít odpověď na toto:

Od verze spring-data-mongo 2.0.0.M4 výše (AFAIK ) MongoTemplate dostal aggregateStream metoda.

Můžete tedy provést následující:

 AggregationOptions aggregationOptions = Aggregation.newAggregationOptions()
        // this is very important: if you do not set the batch size, you'll get all the objects at once and you might run out of memory if the returning data set is too large
        .cursorBatchSize(mongoCursorBatchSize)
        .build();

    data = mongoTemplate.aggregateStream(Aggregation.newAggregation(
            Aggregation.group("person_id").count().as("count")).withOptions(aggregationOptions), collectionName, YourClazz.class);