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.
Genomför den här mikrobatchen med en lista över incheckningsmeddelanden.
Den här metoden anropas på drivrutinen när alla aktiviteter körs. Incheckningsmeddelandena samlas in från metodanropet write() från varje uppgift och skickas till den här metoden. Implementeringen bör använda incheckningsmeddelandena för att checka in mikrobatchen i strömningsmottagaren.
Syntax
commit(messages: List[Optional[WriterCommitMessage]], batchId: int)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
messages |
lista över WriterCommitMessage | En lista över incheckningsmeddelanden. Om en skrivuppgift misslyckas blir Noneincheckningsmeddelandet . |
batchId |
int | Ett heltal som unikt identifierar en batch med data som skrivs. Heltalet ökar med 1 för varje bearbetad mikrobatch. |