outputMode (DataStreamWriter)

Указывает, как данные потокового кадра данных записываются в приемник потоковой передачи.

Синтаксис

outputMode(outputMode)

Параметры

Параметр	Тип	Описание
outputMode	str	Режим вывода. Параметры : append (только новые строки), complete (все строки для каждого обновления) и update (только обновленные строки для каждого обновления; эквивалентны append , если запрос не содержит агрегирования).

Возвраты

DataStreamWriter

Примеры

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

Использование complete режима для печати агрегированных счетчиков:

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