escrever

Escreve dados na fonte de dados.

Este método é chamado uma vez em cada executor para escrever dados na fonte de dados. 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.

Adicionado no Databricks Runtime 14.3 LTS

Sintaxe

write(iterator: Iterator[Row])

Parâmetros

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

Devoluções

WriterCommitMessage

Uma mensagem de commit serializável.