outputMode (DataStreamWriter)

Especifica como os dados de um DataFrame em streaming são escritos para um sink de streaming.

Sintaxe

outputMode(outputMode)

Parâmetros

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

Devoluções

DataStreamWriter

Exemplos

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

Use complete o modo para imprimir contagens agregadas:

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()
  • Last updated on