Я работаю над искровым кодом, в котором я создаю тип геопространственного объекта с использованием коннектора MongoSpark https://docs.mongodb.com/spark-connector/master/java/write-to-mongodb/
JavaRDD<Document> document = ds
.toJavaRDD()
.map(f -> {
Document doc = new Document();
/***************/
List<Double> practice_Cordinates = new ArrayList<Double>();
practice_Cordinates.add(0.0); // Long
practice_Cordinates.add(0.0); // Lat
BasicDBObject GeoSpatial_Obj = new BasicDBObject("type", "Point").
append("coordinates", practice_Cordinates);
/***************/
doc.put("GeoSpatial", GeoSpatial_Obj);
return doc;
});
MongoSpark.save(document);
"GeoSpatial" : {
"coordinates" : [
-73.881631,
40.880462
],
"type" : "Point"
},
Теперь, после того как миллионы записей отправлены, нужно ли использовать типичные монго-java-код для получения коллекции и обновления индекса, предоставив следующий код в java
Spark Code - после MongoSpark.save (DS)
MongoClient mongoClient = new MongoClient();
DBCollection test = mongoClient.getDB("testdb").getCollection("test");
test.createIndex(new BasicDBObject("GeoSpatial","2dsphere"));
Do *Драйвер 1013 * MongoSpark имеет встроенный метод для обработки этого индекса создания, обеспечивает индекс?