如何使用mongodb-spark連接器將數據插入到mongodb中的現有集合

Question

我正在使用mongo-spark連接器來連接spark和MongoDB。 我不能向MongoDB插入數據，因爲spark的默認保存模式是錯誤的，如果「表」（集合）存在 和我試試這個。

MongoSpark.write(centenarians).option("collection", "hundredClub")*.option("mode","append")*.save(); 

但這不是一個效果。 我該怎麼解決這個問題 請幫我謝謝！

這是錯誤消息：

Exception in thread "main" java.lang.UnsupportedOperationException: MongoCollection already exists 

Answer 1

我自己解決這個問題......我 分享這個解決方案（我用的火花語言由斯卡拉）

centenarians.write.format("com.mongodb.spark.sql.DefaultSource").option("collection", "hundredClub").mode("append").save();