为基础数据源添加输出选项。
有关可用选项，请参阅 DataStreamWriter 选项。
Syntax
option(key, value)
参数
| 参数 | 类型 | Description |
|---|---|---|
key |
str | 选项键。 |
value |
str、int、float 或 bool | 选项值。 |
退货
DataStreamWriter
示例
df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>
将每批 3 行打印到控制台：
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").option("numRows", 3).start()
time.sleep(3)
q.stop()