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.
Commits dieses Mikrobatchs mit einer Liste von Commitnachrichten.
Diese Methode wird auf dem Treiber aufgerufen, wenn alle Aufgaben erfolgreich ausgeführt werden. Die Commitnachrichten werden vom write() Methodenaufruf jeder Aufgabe erfasst und an diese Methode übergeben. Die Implementierung sollte die Commitnachrichten verwenden, um den Mikrobatch in der Streaming-Spüle zu übernehmen.
Syntax
commit(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. |