zápis

Zapisuje data do zdroje dat.

Tato metoda se volá jednou pro každý exekutor pro zápis dat do zdroje dat. Přijímá iterátor vstupních dat a vrací jeden řádek představující zprávu potvrzení nebo None pokud zpráva potvrzení neexistuje.

Ovladač shromažďuje potvrzené zprávy, pokud existuje, ze všech exekutorů a předává je metodě commit() , pokud všechny úlohy úspěšně běží. Pokud některý úkol selže, abort() metoda bude volána se shromážděnými zprávami potvrzení.

Přidání do Databricks Runtime 14.3 LTS

Syntaxe

write(iterator: Iterator[Row])

Parametry

Parameter	Typ	Description
iterator	Iterátor[řádek]	Iterátor vstupních dat.

Návraty

WriterCommitMessage

Serializovatelná potvrzovací zpráva.