escribir

Escribe datos en el origen de datos.

Se llama a este método una vez en cada ejecutor para escribir datos en el origen de datos. Acepta un iterador de datos de entrada y devuelve una sola fila que representa un mensaje de confirmación o None si no hay ningún mensaje de confirmación.

El controlador recopila mensajes de confirmación, si los hay, de todos los ejecutores y los pasa al commit() método si todas las tareas se ejecutan correctamente. Si se produce un error en alguna tarea, se llamará al abort() método con los mensajes de confirmación recopilados.

Agregado en Databricks Runtime 14.3 LTS

Sintaxis

write(iterator: Iterator[Row])

Parámetros

Parámetro Tipo Descripción
iterator Iterador[Fila] Iterador de datos de entrada.

Devoluciones

WriterCommitMessage

Un mensaje de confirmación serializable.