Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Skriver data till datakällan.
Den här metoden anropas en gång på varje köre för att skriva data till datakällan. Den accepterar en iterator av indata och returnerar en enda rad som representerar ett incheckningsmeddelande, eller None om det inte finns något incheckningsmeddelande.
Drivrutinen samlar in eventuella incheckningsmeddelanden från alla utförare och skickar dem till commit() metoden om alla aktiviteter körs korrekt. Om någon uppgift misslyckas abort() anropas metoden med de insamlade incheckningsmeddelandena.
Har lagts till i Databricks Runtime 14.3 LTS
Syntax
write(iterator: Iterator[Row])
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
iterator |
Iterator[Rad] | En iterator för indata. |
Retur
WriterCommitMessage
Ett serialiserbart incheckningsmeddelande.