为基础数据源添加多个输出选项。
有关可用选项，请参阅 DataStreamWriter 选项。
Syntax
options(**options)
参数
| 参数 | 类型 | Description |
|---|---|---|
**options |
dict | 选项的键值对。 |
退货
DataStreamWriter
示例
df = spark.readStream.format("rate").load()
df.writeStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamWriter object ...>
在不截断的情况下打印每批 3 行：
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").options(numRows=3, truncate=False).start()
time.sleep(3)
q.stop()