輸出模式（DataStreamWriter）

規定串流資料框架的資料如何寫入串流匯入。

語法

outputMode(outputMode)

參數

參數 類型 說明
outputMode str 輸出模式。 選項有（ append 僅新增列）、 complete （每次更新時的所有列）、以及 update （每次更新僅更新一列;相當於 append 查詢中沒有彙整）。

退貨

DataStreamWriter

Examples

df = spark.readStream.format("rate").load()
df.writeStream.outputMode('append')
# <...streaming.readwriter.DataStreamWriter object ...>

使用 complete 模式列印彙總計數：

import time
df = spark.readStream.format("rate").option("rowsPerSecond", 10).load()
df = df.groupby().count()
q = df.writeStream.outputMode("complete").format("console").start()
time.sleep(3)
q.stop()
  • 上次更新時間：