write

Hiermee schrijft u gegevens naar de gegevensbron.

Deze methode wordt eenmaal aangeroepen voor elke uitvoerder om gegevens naar de gegevensbron te schrijven. Het accepteert een iterator van invoergegevens en retourneert één rij die een doorvoerbericht vertegenwoordigt of None als er geen doorvoerbericht is.

Het stuurprogramma verzamelt doorvoerberichten van alle uitvoerders en geeft deze door aan de commit() methode als alle taken zijn uitgevoerd. Als een taak mislukt, wordt de abort() methode aangeroepen met de verzamelde doorvoerberichten.

Toegevoegd in Databricks Runtime 14.3 LTS

Syntaxis

write(iterator: Iterator[Row])

Parameterwaarden

Retouren

WriterCommitMessage

Een serialiseerbare doorvoeringsbericht.