Я только начал apache-spark с Java. В коллекции сохранено много документов. Я хочу найти документ на основе некоторого ключа и обновить его.
Просто хочу сделать поиск и обновление в apache-spark с java
Это код для чтения формы документа Монго
Map<String, String> readOverrides = new HashMap<String, String>();
readOverrides.put("collection", "bb_playing22");
ReadConfig readConfig = ReadConfig.create(createJavaSparkContext()).withOptions(readOverrides);
JavaMongoRDD<Document> customRdd = MongoSpark.load(createJavaSparkContext(), readConfig);
JavaRDD<Document> rdd = customRdd.filter(((t1) -> {
return t1.getLong("playing22_id") == 3; //To change body of generated lambdas, choose Tools | Templates.
}));
но не может обновить этот документ