Měli byste použít MongoConnector
.
Zvládne vytvoření kolekce a je podporován mezipamětí, která efektivně zvládá vypnutí všech MongoClientů. Je serializovatelný, takže to může být vysílání a může vyžadovat možnosti, readConfig nebo kontext Spark pro konfiguraci, kam se má připojit.
MongoConnector používá vzor půjčky ke správě referencí základního připojení k MongoDB a umožňuje přístup na MongoClient , MongoDatabase nebo MongoCollection úroveň.