write (DataSourceStreamWriter)

Escreve dados no sumidouro de streaming.

Este método é chamado aos executores para escreverem dados no sumidouro de dados em streaming em cada microlote. Aceita um iterador de dados de entrada e devolve uma única linha que representa uma mensagem de commit, ou None se não houver mensagem de commit.

O driver recolhe mensagens de commit, se existirem, de todos os executores e passa-as para o commit() método se todas as tarefas correrem com sucesso. Se alguma tarefa falhar, o abort() método será chamado com as mensagens de commit recolhidas.

Sintaxe

write(iterator: Iterator[Row])

Parâmetros

Devoluções

WriterCommitMessage

Uma mensagem de commit serializável.