Powinieneś użyć MongoConnector
.
Zajmie się tworzeniem kolekcji i jest wspierany przez pamięć podręczną, która skutecznie obsługuje zamykanie dowolnych MongoClients. Można go serializować, więc może być rozgłoszeniem i może brać opcje, readConfig lub kontekst Spark, aby skonfigurować, gdzie się połączyć.
MongoConnector używa wzorca pożyczki do obsługi zarządzania odniesieniami podstawowego połączenia z MongoDB i umożliwia dostęp w MongoClient , MongoDatabase lub MongoCollection poziom.
