新增底層資料來源的輸出選項。
關於可用選項,請參閱 DataStreamWriter 選項。
語法
option(key, value)
參數
| 參數 | 類型 | 說明 |
|---|---|---|
key |
str | Option 鍵。 |
value |
力量、智力、浮點或布爾 | 選擇權價值。 |
退貨
DataStreamWriter
Examples
df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>
每批列印三列到控制台:
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").option("numRows", 3).start()
time.sleep(3)
q.stop()