選項（DataStreamWriter）

為底層資料來源新增多種輸出選項。

關於可用選項，請參閱 DataStreamWriter 選項。

語法

options(**options)

參數

參數	類型	說明
**options	dict	關鍵值期權對。

退貨

DataStreamWriter

Examples

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()