Pular para o conteúdo principal

escrever

Grava 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 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.

Adicionado no Databricks Runtime 14.3 LTS

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.