options （DataStreamReader）

为基础数据源添加多个输入选项。

Syntax

options(**options)

参数

参数	类型	说明
**options	dict	选项的键值对。

退货

DataStreamReader

示例

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

将选项指定为字典：

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

使用 Rate 源生成每秒 10 行，其中包含 10 个分区：

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