write (DataSourceStreamWriter)

Grava dados no coletor de streaming.

Esse método é chamado aos executores para gravar dados no coletor de dados de streaming em cada microbatch. Ele aceita um iterador de dados de entrada e retorna uma única linha que representa uma mensagem de confirmação ou None se não há nenhuma mensagem de confirmação.

O driver coleta mensagens de confirmação, se houver, de todos os executores e as passa para o commit() método se todas as tarefas forem executadas com êxito. Se qualquer tarefa falhar, o abort() método será chamado com as mensagens de confirmação coletadas.

Sintaxe

write(iterator: Iterator[Row])

Parâmetros

Devoluções

WriterCommitMessage

Uma mensagem de confirmação serializável.