Vous devez utiliser le MongoConnector
.
Il gérera la création d'une collection et est soutenu par un cache qui gère efficacement l'arrêt de tous les MongoClients. Il est sérialisable, il peut donc s'agir d'une diffusion et il peut prendre des options, un readConfig ou le contexte Spark pour configurer où se connecter.
MongoConnector utilise le modèle de prêt pour gérer la gestion des références de la connexion sous-jacente à MongoDB et permet l'accès au MongoClient , MongoDatabase ou la MongoCollection niveau.
