escrever (DataSourceStreamWriter)

Grava dados no coletor de transmissão.

Este método é chamado no executor para gravar dados no coletor de dados de transmissão em cada microlote. Aceita um iterador de dados de entrada e retorna uma única linha representando uma mensagem de commit, ou None se não houver mensagem de commit.

O driver coleta mensagens commit , se houver, de todos os executores e as passa para o método commit() se todas as execuções de tarefas forem bem-sucedidas. Se alguma tarefa falhar, o método abort() será chamado com as mensagens de commit coletadas.

Sintaxe

write(iterator: Iterator[Row])

Parâmetros

Parâmetro	Tipo	Descrição
iterator	Iterador[Linha]	Um iterador de dados de entrada.

Devoluções

WriterCommitMessage

Uma mensagem de commit serializável.