選項（DataStreamReader）

新增底層資料來源的輸入選項。

關於可用選項，請參閱 DataStreamReader 選項。

語法

option(key, value)

參數

參數	類型	說明
key	str	Option 鍵。
value	力量、智力、浮點或布爾	選擇權價值。

退貨

DataStreamReader

Examples

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

使用 Rate 來源每秒產生 10 列：

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