outputMode (DataStreamWriter)

Especifica cómo se escriben los datos de un DataFrame de streaming en un receptor de streaming.

Sintaxis

outputMode(outputMode)

Parámetros

Parámetro Tipo Descripción
outputMode str Modo de salida. Las opciones son append (solo filas nuevas), complete (todas las filas de cada actualización) y update (solo las filas actualizadas en cada actualización; equivalente a append si la consulta no contiene agregaciones).

Devoluciones

DataStreamWriter

Ejemplos

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

Use complete el modo para imprimir recuentos agregados:

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