Debe usar MongoConnector
.
Manejará la creación de una colección y está respaldado por un caché que maneja de manera eficiente el cierre de cualquier MongoClients. Es serializable, por lo que puede ser una transmisión y puede tomar opciones, un readConfig o el contexto Spark para configurar dónde conectarse.
MongoConnector utiliza el patrón de préstamo para gestionar la gestión de referencias de la conexión subyacente a MongoDB y permite el acceso a MongoClient , MongoDatabase o la MongoCollection nivel.
