出力モード（データストリームライター）

ストリーミングDataFrameのデータをストリーミング シンクに書き込む方法を指定します。

構文

outputMode(outputMode)

パラメーター

パラメーター	Type	説明
outputMode	str	出力モード。オプションは、 append （新規行のみ）、 complete （更新のたびにすべての行）、 update （更新のたびに更新された行のみ。クエリに集計が含まれていない場合はappendと同等）です。

戻り値

DataStreamWriter

例

Python

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

集計されたカウントを表示するには、 completeモードを使用してください。

Python

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