outputMode (DataStreamWriter)

Menentukan bagaimana data DataFrame streaming ditulis ke sink streaming.

Sintaksis

outputMode(outputMode)

Parameter-parameternya

Parameter	Tipe	Deskripsi
outputMode	str	Mode output. Opsinya adalah append (hanya baris baru), complete (semua baris pada setiap pembaruan), dan update (hanya baris yang diperbarui pada setiap pembaruan; setara dengan append jika kueri tidak berisi agregasi).

Pengembalian Barang

DataStreamWriter

Examples

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

Gunakan complete mode untuk mencetak jumlah agregat:

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