Агрегат очень медленный Скала

Question

Мне нужна помощь, потому что я не знаю, почему мой агрегат очень медленный. У меня есть одна база данных с 2 коллекциями:

пользователей (идентификатор, имя, адрес электронной почты) с 40 000 элементов

сообщений (идентификатор, автор, контент) с 39 000 элементов

Я хочу знать все сообщения, опубликованные пользователем. Я использую Casbah, и это мой код:

val aggregationOptions = AggregationOptions(AggregationOptions.CURSOR)
val content_return = 
MongoClient("localhost", 27017)("Blog")("users").aggregate(
List(MongoDBObject("$lookup" -> MongoDBObject("from" -> "posts", "localField" -> "name", "foreignField" -> "author", "as" -> "posts")),
     MongoDBObject("$unwind" -> "$posts")),
     aggregationOptions)

Если у кого-то есть идея, большое спасибо!