write (DataSourceStreamWriter)

Escribe datos en el receptor de streaming.

Este método se llama a los ejecutores para escribir datos en el receptor de datos de streaming en cada microbatch. 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.

Sintaxis

write(iterator: Iterator[Row])

Parámetros

Devoluciones

WriterCommitMessage

Un mensaje de confirmación serializable.