Hi Team
While MongoSpark reader has a way of configuring custom MongConnector using Builder instance, but something similar is not available for MongoSpark writer. We are requesting a save API in MongoSpark that accepts MongoConnector as an additional input:
def save(rdd: RDD[BsonDocument], writeConfig: WriteConfig, mongoConnector: MongoConnector): Unit
One use case for which we need this is - we need to build a custom MongoClient with X509 credentials as part of MongoClientFactory#create method and use this to build a MongoConnector instance.
Also I was wondering if I can submit a PR for this? We added this API in-house and were able to utilize it.
- related to
-
SPARK-343 Extend methods accepting MongoConnector argument to some more MongoSpark SAVE methods
- Closed