ストリーミング データフレームのデータをストリーミング シンクに書き込む方法を指定します。
構文
outputMode(outputMode)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
outputMode |
str | 出力モード。 オプションは、 append (新しい行のみ)、 complete (更新ごとにすべての行)、 update (更新ごとに更新された行のみ、クエリに集計が含まれている場合の append と同等) です。 |
返品
DataStreamWriter
例示
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()