sql >> Database >  >> NoSQL >> MongoDB

Spark - Hoe maak je een variabele die voor elke uitvoerdercontext anders is?

Gebruik de MongoConnector .

Het zorgt voor het maken van een verzameling en wordt ondersteund door een cache die het afsluiten van MongoClients efficiënt afhandelt. Het is serialiseerbaar, dus het kan een uitzending zijn en er kunnen opties, een readConfig of de Spark-context nodig zijn om te configureren waar verbinding mee moet worden gemaakt.

MongoConnector gebruikt het leenpatroon om het referentiebeheer van de onderliggende verbinding met MongoDB af te handelen en geeft toegang bij de MongoClient , MongoDatabase of de MongoCollection niveau.




  1. Mongoose-aggregaat, kan niet dynamisch iets toevoegenVeld:{ $not; nul }

  2. Verwijder element uit geneste array mongodb

  3. Hoe voeg ik een automatisch oplopend veld toe aan MongoDB-aggregaat?

  4. In MongoDB, hoe een query uit te voeren op basis van of een tekenreeksveld een ander bevat?