2017-08-25 9 views
1

私はspongとMongoDBの間を接続するためにmongo-sparkコネクタを使用しています。 私はMongoDBにデータを挿入できませんでした。なぜなら、「テーブル」(コレクション)が存在する場合、デフォルトの保存モードがエラーになります。 と私はこれを試しています。mongodb-sparkコネクタでmongodbの既存のコレクションにデータを挿入する方法

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

しかし、これは影響ありません。 どうすればこの問題を解決できますか ありがとう!

これはエラーメッセージです:

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

答えて

1

私は自分でこの問題を解決する... 私はこの解決策を共有する(私はスカラ座で火花言語を使用)

centenarians.write.format("com.mongodb.spark.sql.DefaultSource").option("collection", "hundredClub").mode("append").save(); 
関連する問題