Du skal bruge MongoConnector
.
Det vil håndtere oprettelse af en samling og er understøttet af en cache, der effektivt håndterer nedlukningen af enhver MongoClients. Det kan serialiseres, så det kan være en udsendelse, og det kan tage valgmuligheder, en readConfig eller Spark-konteksten for at konfigurere, hvor der skal oprettes forbindelse til.
MongoConnector bruger lånemønsteret til at håndtere referencestyring af den underliggende forbindelse til MongoDB og tillader adgang på MongoClient , MongoDatabase eller MongoCollection niveau.