option (DataStreamWriter)

Добавляет параметр вывода для базового источника данных.

Доступные параметры см. в разделе "Параметры DataStreamWriter".

Синтаксис

option(key, value)

Параметры

Параметр	Тип	Описание
key	str	Клавиша Option.
value	str, int, float или bool	Значение параметра.

Возвраты

DataStreamWriter

Примеры

df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>

Печать 3 строк на пакет в консоль:

import time
q = spark.readStream.format(
    "rate").option("rowsPerSecond", 10).load().writeStream.format(
        "console").option("numRows", 3).start()
time.sleep(3)
q.stop()