Overview
Puedes configurar las siguientes propiedades cuando escribas datos en MongoDB en modo de agrupar.
Nota
Si usas SparkConf para configurar las opciones de escritura del conector, añade el prefijo spark.mongodb.write. a cada propiedad.
Nombre de la propiedad | Descripción | |
|---|---|---|
| Requerido. | |
| Requerido. | |
| Requerido. | |
| Comentario que se añadirá a la operación de escritura. Los comentarios aparecen en la salida del Generador de perfiles de base de datos. Valor | |
| Clave de configuración de MongoClientFactory. Puede | |
| Especifica si el conector analiza los valores de cadena y convierte el JSON extendido en BSON.
Por defecto: | |
| Especifica un campo o una lista de campos por los que dividir los datos de la colección. Para especificar más de un campo, sepárelos con una coma, como se muestra en el siguiente ejemplo: Por defecto: | |
|
| |
| Especifica el número máximo de operaciones a agrupar en operaciones masivas. | |
| Especifica el tipo de operación de guardar a realizar. Puedes configurar una de las siguientes opciones:
| |
| Especifica si se deben realizar operaciones masivas ordenadas. | |
|
| |
| Especifica, una opción de confirmación de escritura que solicita que se confirme que la operación de escritura se ha propagado a un número determinado de nodos de MongoDB. | |
| Especifica, una opción de confirmación de escritura que solicita que se confirme que los datos se han escrito en el registro en disco según los criterios especificados en la | |
|
| |
| Cuando |
Especificando propiedades en connection.uri
Si utiliza SparkConf para especificar cualquiera de las configuraciones anteriores, puede incluirlas en la configuración connection.uri o enumerarlas individualmente.
El siguiente ejemplo de código muestra cómo especificar la base de datos, la colección y la configuración de convertJson como parte de la configuración de connection.uri:
spark.mongodb.write.connection.uri=mongodb://127.0.0.1/myDB.myCollection?convertJson=any
Para mantener el connection.uri más breve y hacer que la configuración sea más fácil de leer, puedes especificarlos individualmente en su lugar:
spark.mongodb.write.connection.uri=mongodb://127.0.0.1/ spark.mongodb.write.database=myDB spark.mongodb.write.collection=myCollection spark.mongodb.write.convertJson=any
Importante
Si especifica una configuración tanto en el connection.uri como en su propia línea, la configuración de connection.uri tiene prioridad. Por ejemplo, en la siguiente configuración, la base de datos de conexión es foobar:
spark.mongodb.write.connection.uri=mongodb://127.0.0.1/foobar spark.mongodb.write.database=bar