如何通过使用Spark Java匹配文件中的数据来将数据更新到MongoDB中

Question

我正在读MongoDB收集的数据

String ipuri = "mongodb://127.0.0.1/mydb.data";
String opuri = "mongodb://127.0.0.1/mydb.data";

SparkConf conf = new SparkConf().setMaster("local").setAppName("InsertData")
                .set("spark.mongodb.input.uri", ipuri).set("spark.mongodb.output.uri", opuri)
                .set("spark.app.id", "InsertData")
                .set("spark.driver.allowMultipleContexts", "true");
JavaSparkContext jsc = new JavaSparkContext(conf);
JavaMongoRDD<Document> mongodata = MongoSpark.load(jsc);

接下来我还要读一个json文件

Dataset<Row> df = sqlContext.read().json("/home/praveen/report.json");

现在我想匹配报告中的值。json&；MongoDB。如果匹配，我必须将json文件中的数据更新到MongoDB中

如果我使用foreach添加到列表中。。我得到一张空名单

List list= new ArrayList();
df.foreach(x-> {list.add(x);});
System.out.println(list);