outputMode (DataStreamWriter)

Určuje, jak se data streamovaného datového rámce zapisuje do jímky streamování.

Syntaxe

outputMode(outputMode)

Parametry

Parameter	Typ	Description
outputMode	str	Výstupní režim. Možnosti jsou append (pouze nové řádky), complete (všechny řádky při každé aktualizaci) a update (pouze aktualizované řádky při každé aktualizaci; ekvivalentní append , pokud dotaz neobsahuje žádné agregace).

Návraty

DataStreamWriter

Příklady

df = spark.readStream.format("rate").load()
df.writeStream.outputMode('append')
# <...streaming.readwriter.DataStreamWriter object ...>

Tisk agregovaných počtů pomocí complete režimu:

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()