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 direktuppspelningsmottagaren.
Den här metoden uppmanas utförare att skriva data till den strömmande datamottagaren i varje mikrobatch. 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.
Syntax
write(iterator: Iterator[Row])
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
iterator |
Iterator[Rad] | En iterator för indata. |
Retur
WriterCommitMessage
Ett serialiserbart incheckningsmeddelande.