utlösare (DataStreamWriter)

Anger utlösaren för strömningsfrågan. Om den inte har angetts körs frågan så snabbt som möjligt, vilket motsvarar processingTime='0 seconds'. Endast en utlösarparameter kan anges i taget.

Mer information finns i Konfigurera utlösarintervall för strukturerad direktuppspelning.

Syntax

trigger(*, processingTime=None, once=None, continuous=None, availableNow=None, realTime=None)

Parameters

Parameter	Type	Beskrivning
processingTime	str, valfritt	En tidsintervallsträng för bearbetning (till exempel '5 seconds', '1 minute'). Kör en mikrobatchfråga med jämna mellanrum baserat på bearbetningstiden.
once	bool, valfritt	Om Truebearbetar endast en batch data avslutar frågan.
continuous	str, valfritt	En tidsintervallsträng (till exempel '5 seconds'). Kör en kontinuerlig fråga med ett angivet kontrollpunktsintervall.
availableNow	bool, valfritt	Om True, bearbetar alla tillgängliga data i flera batchar avslutas frågan.
realTime	str, valfritt	En batchvaraktighetssträng (till exempel '5 seconds'). Kör en realtidslägesfråga med batchar under den angivna varaktigheten.

Retur

DataStreamWriter

Exempel

df = spark.readStream.format("rate").load()

Utlösarkörning var 5:e sekund:

df.writeStream.trigger(processingTime='5 seconds')
# <...streaming.readwriter.DataStreamWriter object ...>

Utlös kontinuerlig körning var 5:e sekund:

df.writeStream.trigger(continuous='5 seconds')
# <...streaming.readwriter.DataStreamWriter object ...>

Bearbeta alla tillgängliga data i flera batchar:

df.writeStream.trigger(availableNow=True)
# <...streaming.readwriter.DataStreamWriter object ...>

Utlös realtidskörning var 5:e sekund:

df.writeStream.trigger(realTime='5 seconds')
# <...streaming.readwriter.DataStreamWriter object ...>