Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Hiermee geeft u op hoe gegevens van een streaming DataFrame naar een streaming-sink worden geschreven.
Syntaxis
outputMode(outputMode)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
outputMode |
str | Uitvoermodus. Opties zijn append (alleen nieuwe rijen), complete (alle rijen in elke update) en update (alleen bijgewerkte rijen in elke update; gelijk aan append als de query geen aggregaties bevat). |
Retouren
DataStreamWriter
Examples
df = spark.readStream.format("rate").load()
df.writeStream.outputMode('append')
# <...streaming.readwriter.DataStreamWriter object ...>
Gebruik complete de modus voor het afdrukken van geaggregeerde aantallen:
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()