選項（DataStreamReader）

為底層資料來源新增多種輸入選項。

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

語法

options(**options)

參數

參數	類型	說明
**options	dict	關鍵值期權對。

退貨

DataStreamReader

Examples

spark.readStream.options(x="1", y=2)
# <...streaming.readwriter.DataStreamReader object ...>

以字典形式指定選項：

spark.readStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamReader object ...>

利用速率來源產生每秒 10 列、10 個分割：

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