Anda harus menggunakan MongoConnector
.
Ini akan menangani pembuatan koleksi dan didukung oleh cache yang secara efisien menangani penutupan setiap MongoClients. Ini dapat serial sehingga dapat menjadi siaran dan dapat mengambil opsi, readConfig atau konteks Spark untuk mengonfigurasi tempat untuk terhubung.
MongoConnector menggunakan pola pinjaman untuk menangani manajemen referensi dari koneksi yang mendasari ke MongoDB dan memungkinkan akses di MongoClient , MongoDatabase atau MongoCollection tingkat.
