outputMode (DataStreamWriter)

Określa sposób zapisywania danych przesyłania strumieniowego w ujściu przesyłania strumieniowego.

Składnia

outputMode(outputMode)

Parametry

Parameter	Typ	Opis
outputMode	str	Tryb wyjściowy. Opcje to append (tylko nowe wiersze), complete (wszystkie wiersze w każdej aktualizacji) i update (tylko zaktualizowane wiersze w każdej aktualizacji; równoważne append , jeśli zapytanie nie zawiera agregacji).

Zwroty

DataStreamWriter

Examples

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

Użyj complete trybu, aby wydrukować zagregowane liczby:

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