選項(DataStreamWriter)

新增底層資料來源的輸出選項。

關於可用選項,請參閱 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()