MongoDB工具 >MongoDB Spark连接器 >Spark Connector Scala指南 > 写入MongoDB
将RDD数据保存到MongoDB时,该数据必须可转换为BSON文档。您可能需要包括
map
转换将数据转换成一个Document
(或
BsonDocument
或DBObject
)。
以下示例创建一个10文档的RDD并将其保存到在中指定的MongoDB集合中SparkConf
:
WriteConfig
MongoSpark.save()
可以接受WriteConfig
指定各种写配置设置(例如集合或写关注)的对象。
例如,以下代码将数据保存到spark
集合中,并具有majority
写注意事项:
RDD具有隐式的辅助方法saveToMongoDB()
,可将数据写入MongoDB:
例如,以下代码使用documents
上面定义的RDD并使用saveToMongoDB()
不带任何参数的方法将文档保存到在中指定的集合中SparkConf
:
调用saveToMongoDB()
一个WriteConfig
对象以指定其他MongoDB服务器地址,数据库和集合。请参阅
写入配置设置以获取可用设置:
某些Scala类型(例如Lists
)不受支持,应将其转换为Java等效。要从Scala转换成本机类型,请包含以下import语句以使用该.asJava
方法:
以下操作将导入.asJava
方法,将Scala列表转换为其等效的Java,然后将其保存到MongoDB: