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.
Avbryter den här mikrobatchen på grund av aktivitetsfel.
Den här metoden anropas på drivrutinen när en eller flera uppgifter misslyckades. 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 avbryta mikrobatchen i strömningsmottagaren.
Syntax
abort(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. |