Spark - Hur skapar man en variabel som är olika för varje exekutorkontext?

Du bör använda MongoConnector .

Den kommer att hantera att skapa en samling och stöds av en cache som effektivt hanterar avstängningen av alla MongoClients. Det är serialiserbart så det kan vara en sändning och det kan ta alternativ, en readConfig eller Spark-kontexten för att konfigurera var den ska anslutas.

MongoConnector använder lånemönstret för att hantera referenshantering av den underliggande kopplingen till MongoDB och tillåter åtkomst på MongoClient , MongoDatabase eller MongoCollection nivå.