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.
Gibt an, wie Daten eines Streaming-DataFrames in eine Streaming-Spüle geschrieben werden.
Syntax
outputMode(outputMode)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
outputMode |
str | Ausgabemodus. Optionen sind append (nur neue Zeilen), complete (alle Zeilen bei jeder Aktualisierung) und update (nur aktualisierte Zeilen für jede Aktualisierung; entspricht dem append , wenn die Abfrage keine Aggregationen enthält). |
Rückkehr
DataStreamWriter
Beispiele
df = spark.readStream.format("rate").load()
df.writeStream.outputMode('append')
# <...streaming.readwriter.DataStreamWriter object ...>
Verwenden Sie complete den Modus zum Drucken aggregierter Anzahlen:
import time
df = spark.readStream.format("rate").option("rowsPerSecond", 10).load()
df = df.groupby().count()
q = df.writeStream.outputMode("complete").format("console").start()
time.sleep(3)
q.stop()