Трябва да използвате MongoConnector
.
Той ще се справи със създаването на колекция и е подкрепен от кеш, който ефективно се справя с изключването на всеки MongoClients. Може да се сериализира, така че може да бъде излъчване и може да приема опции, readConfig или контекста на Spark, за да конфигурира къде да се свърже.
MongoConnector използва шаблона за заемане, за да управлява управлението на препратките на основната връзка към MongoDB и позволява достъп до MongoClient , MongoDatabase или MongoCollection ниво.
