Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Specifica il modo in cui i dati di un dataframe di streaming vengono scritti in un sink di streaming.
Sintassi
outputMode(outputMode)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
outputMode |
str | Modalità di output. Le opzioni sono append (solo nuove righe), complete (tutte le righe di ogni aggiornamento) e update (solo le righe aggiornate per ogni aggiornamento; equivalenti a append se la query non contiene aggregazioni). |
Restituzioni
DataStreamWriter
Examples
df = spark.readStream.format("rate").load()
df.writeStream.outputMode('append')
# <...streaming.readwriter.DataStreamWriter object ...>
Usare complete la modalità per stampare i conteggi aggregati:
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()