如何使用Apache Spark JavaRDDs在MongoDB中查询？

SparkConf sparkConf = new SparkConf()
    .setAppName("MongoDBExample")
    .setMaster("local[*]"); // 设置Spark的运行模式

JavaSparkContext sparkContext = new JavaSparkContext(sparkConf);

Map<String, String> mongoOptions = new HashMap<>();
mongoOptions.put("spark.mongodb.input.uri", "mongodb://localhost/test.collection");
mongoOptions.put("spark.mongodb.output.uri", "mongodb://localhost/test.collection");

JavaMongoRDD<Document> mongoRDD = MongoSpark.load(sparkContext, ReadConfig.create(sparkContext).withOptions(mongoOptions));

JavaRDD<Document> filteredRDD = mongoRDD.filter(doc -> doc.getInteger("age") >= 18);

List<Document> result = filteredRDD.collect();
for (Document doc : result) {
    System.out.println(doc.toJson());
}

<dependency>
    <groupId>org.mongodb.spark</groupId>
    <artifactId>mongo-spark-connector_2.12</artifactId>
    <version>3.0.1</version>
</dependency>