modo de saída (DataStreamWriter)

Especifica como os dados de um DataFrame de transmissão são gravados em um coletor de transmissão.

Sintaxe

outputMode(outputMode)

Parâmetros

Parâmetro	Tipo	Descrição
outputMode	str	Modo de saída. As opções são append (somente linhas novas), complete (todas as linhas em cada atualização) e update (somente linhas atualizadas em cada atualização; equivalente a append se a consulta não contiver agregações).

Devoluções

DataStreamWriter

Exemplos

Python

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

Use o modo complete para imprimir as contagens agregadas:

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