Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Deze microbatch wordt afgebroken vanwege taakfouten.
Deze methode wordt aangeroepen op het stuurprogramma wanneer een of meer taken zijn mislukt. De doorvoerberichten worden verzameld vanuit de write() methode-aanroep van elke taak en doorgegeven aan deze methode. De implementatie moet de doorvoerberichten gebruiken om de microbatch in de streaming-sink af te breken.
Syntaxis
abort(messages: List[Optional[WriterCommitMessage]], batchId: int)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
messages |
lijst met WriterCommitMessage | Een lijst met doorvoerberichten. Als een schrijftaak mislukt, wordt het doorvoerbericht weergegeven None. |
batchId |
int | Een geheel getal dat een batch met gegevens identificeert die wordt geschreven. Het gehele getal neemt toe met 1 terwijl elke microbatch is verwerkt. |