Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Bricht diese Mikrobatch aufgrund von Vorgangsfehlern ab.
Diese Methode wird auf dem Treiber aufgerufen, wenn mindestens eine Aufgabe fehlgeschlagen ist. Die Commitnachrichten werden vom write() Methodenaufruf jeder Aufgabe erfasst und an diese Methode übergeben. Die Implementierung sollte die Commitnachrichten verwenden, um die Mikrobatch in der Streaming-Spüle abzubrechen.
Syntax
abort(messages: List[Optional[WriterCommitMessage]], batchId: int)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
messages |
Liste von WriterCommitMessage | Eine Liste der Commit-Nachrichten. Wenn eine Schreibaufgabe fehlschlägt, lautet Nonedie Commit-Nachricht . |
batchId |
int | Eine ganze Zahl, die einen Batch geschriebener Daten eindeutig identifiziert. Die ganze Zahl erhöht sich um 1, wobei jedes Mikrobatch verarbeitet wird. |