Я использую mongodb / mongo-hadoop (https://github.com/mongodb/mongo-hadoop/wiki/Spark-Usage#python-example), но был сбит с толку из-за того, как я могу выполнять параллельные операции чтения.
С помощью параллельных операций чтения можно выполнять параллельную операцию чтения для моего индекса MongoDB. Я проиндексировал свою БД на основе метки времени и хочу параллельно запрашивать данные T1-T2, T3-T4 и т. Д.