Compartilhar via

outputMode (DataStreamWriter)

Especifica como os dados de um DataFrame de streaming são gravados em um coletor 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 (somente 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 o complete 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