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

Reply via email to