outputMode (DataStreamWriter)

Spécifie comment les données d'un DataFrame de streaming sont écrites dans un récepteur de streaming.

Syntaxe

outputMode(outputMode)

parameter

parameter	Type	Description
outputMode	str	Mode de sortie. Les options sont append (uniquement les nouvelles lignes), complete (toutes les lignes à chaque mise à jour) et update (uniquement les lignes mises à jour à chaque mise à jour ; équivalent à append si la query ne contient aucune agrégation).

parameter	Type	Description
outputMode	str	Mode de sortie. Les options sont append (uniquement les nouvelles lignes), complete (toutes les lignes à chaque mise à jour) et update (uniquement les lignes mises à jour à chaque mise à jour ; équivalent à append si la query ne contient aucune agrégation).

Renvoie

DataStreamWriter

Exemples

Python

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

Utilisez le mode complete pour afficher les totaux agrégés :

Python

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