outputMode (DataStreamWriter)

Bir akış DataFrame'in verilerinin akış havuzuna nasıl yazılması olduğunu belirtir.

Sözdizimi

outputMode(outputMode)

Parametreler

Parametre	Türü	Açıklama
outputMode	str	Çıkış modu. Seçenekler şunlardır (yalnızca yeni satırlar append ), complete (her güncelleştirmedeki tüm satırlar) ve update (her güncelleştirmede yalnızca güncelleştirilmiş satırlar; sorgu toplama içermiyorsa buna eşdeğerdir append ).

İadeler

DataStreamWriter

Örnekler

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

Toplu sayıları yazdırmak için modu kullanın 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()