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.
Schreibt Daten in die Datenquelle.
Diese Methode wird einmal für jeden Executor aufgerufen, um Daten in die Datenquelle zu schreiben. Sie akzeptiert einen Iterator von Eingabedaten und gibt eine einzelne Zeile zurück, die eine Commit-Nachricht darstellt, oder None wenn keine Commitnachricht vorhanden ist.
Der Treiber sammelt commit-Nachrichten( falls vorhanden) von allen Executoren und übergibt sie an die commit() Methode, wenn alle Aufgaben erfolgreich ausgeführt werden. Wenn eine Aufgabe fehlschlägt, wird die abort() Methode mit den gesammelten Commit-Nachrichten aufgerufen.
Hinzugefügt in Databricks Runtime 14.3 LTS
Syntax
write(iterator: Iterator[Row])
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
iterator |
Iterator[Zeile] | Ein Iterator von Eingabedaten. |
Rückkehr
WriterCommitMessage
Eine serialisierbare Commitnachricht.