添加基础数据源的输入选项。
Syntax
option(key, value)
参数
| 参数 | 类型 | Description |
|---|---|---|
key |
str | 选项键。 |
value |
str、int、float 或 bool | 选项值。 |
退货
DataStreamReader
示例
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()