параметр (DataStreamReader)

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

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

Синтаксис

option(key, value)

Параметры

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

Возвраты

DataStreamReader

Примеры

spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>

Создайте 10 строк в секунду с помощью источника rate:

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