write

Записывает данные в источник данных.

Этот метод вызывается один раз для каждого исполнителя для записи данных в источник данных. Он принимает итератор входных данных и возвращает одну строку, представляющую сообщение фиксации, или None если нет сообщения фиксации.

Драйвер собирает сообщения фиксации, если таковые есть, от всех исполнителей и передает их методу commit() , если все задачи выполняются успешно. Если любая задача завершается ошибкой, abort() метод будет вызываться с собранными сообщениями фиксации.

Добавлено в Databricks Runtime 14.3 LTS

Синтаксис

write(iterator: Iterator[Row])

Параметры

Параметр	Тип	Описание
iterator	Итератор[Строка]	Итератор входных данных.

Возвраты

WriterCommitMessage

Сериализуемое сообщение о фиксации.