mongodb - Spark：Mongo-Hadoop如何查询

Question

我正在尝试使用 Spark 和 mongo-hadoop 对 MongoDB 进行 $near 查询，其中纬度/经度坐标发生了变化。如何使用 mongo-hadoop 进行查询？

除了像这样的东西：

mongodbConfig.set("mongo.input.query", "{'field':'value'}")我看不到任何有理智的东西。

任何想法？

Answer 1

我建议你可以看看com.mongodb.hadoop.util.MongoConfigUtil，有很多配置查询设置：

mongodbConfig.set("mongo.input.query","{key:{\"$eq\":20160517080039}}");
mongodbConfig.set("mongo.input.fields","{key:0}");
mongodbConfig.setInt("mongo.input.limit", 1);