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 Streaming-Spüle.
Diese Methode wird für Executoren aufgerufen, um Daten in die Streamingdatensenke in jedem Mikrobatch 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.
Syntax
write(iterator: Iterator[Row])
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
iterator |
Iterator[Zeile] | Ein Iterator von Eingabedaten. |
Rückkehr
WriterCommitMessage
Eine serialisierbare Commitnachricht.