Hi,
I am using below code to insert data in mongodb from spark.
JavaPairRDD<Object, BSONObject> rdd;
Configuration config = new Configuration();
config.set("mongo.output.uri", SparkProperties.MONGO_OUTPUT_URI);
config.set("mongo.output.format",
"com.mongodb.hadoop.MongoOutputFormat");
rdd.saveAsNewAPIHadoopFile("file:///notapplicable",
Object.class, BSONObject.class,
MongoOutputFormat.class, config);
But, looking in the code i am not able to figure out what write concern
api's are using to insert data in mongodb.
Please explain and let me know if someone figure out.
Thanks,
Deepesh