outputMode (DataStreamWriter)

Anger hur data för en strömmande DataFrame skrivs till en direktuppspelningsmottagare.

Syntax

outputMode(outputMode)

Parameters

Parameter Type Beskrivning
outputMode str Utdataläge. Alternativen är append (endast nya rader), complete (alla rader vid varje uppdatering) och update (endast uppdaterade rader vid varje uppdatering, vilket motsvarar append om frågan inte innehåller några sammansättningar).

Retur

DataStreamWriter

Exempel

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

Använd complete läge för att skriva ut aggregerade antal:

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()
  • Last updated on