MongoDB工具 >MongoDB Spark连接器 >Spark Connector Scala指南 > 从MongoDB读取
使用该MongoSpark.load
方法创建代表集合的RDD。
以下示例加载在中指定的集合
SparkConf
:
要指定其他集合,数据库和其他读取配置设置,请将传递ReadConfig
给
MongoSpark.load()
。
ReadConfig
MongoSpark.load()
可以接受ReadConfig
指定各种读取配置设置的对象,例如集合或
读取首选项。
以下示例spark
以secondaryPreferred
优先级从集合中
读取:
SparkContext
有一个隐式的辅助方法loadFromMongoDB()
,用于从MongoDB加载数据。
例如,使用loadFromMongoDB()
不带任何参数的方法来加载在中指定的集合SparkConf
:
调用loadFromMongoDB()
一个ReadConfig
对象以指定其他MongoDB服务器地址,数据库和集合。请参阅
输入配置设置以获取可用设置: