Как использовать соединитель MongoSpark для создания индекса 2dshere? - PullRequest
1 голос
/ 23 сентября 2019

Я работаю над искровым кодом, в котором я создаю тип геопространственного объекта с использованием коннектора 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 имеет встроенный метод для обработки этого индекса создания, обеспечивает индекс?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...