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

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

構文

outputMode(outputMode)

パラメーター

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

パラメーター	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()