trigger (DataStreamWriter)

Nastaví aktivační událost pro dotaz streamování. Pokud není nastavený, dotaz se spustí co nejrychleji, což odpovídá processingTime='0 seconds'. Najednou je možné nastavit pouze jeden parametr triggeru.

Další informace najdete v tématu Konfigurace intervalů aktivačních událostí strukturovaného streamování.

Syntaxe

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

Parametry

Parameter	Typ	Description
processingTime	str, volitelné	Řetězec časového intervalu zpracování (například '5 seconds', '1 minute'). Pravidelně spouští dotaz microbatch na základě doby zpracování.
once	bool, volitelné	Pokud Truezpracuje pouze jednu dávku dat, dotaz se ukončí.
continuous	str, volitelné	Řetězec časového intervalu (například '5 seconds'). Spustí průběžný dotaz s daným intervalem kontrolního bodu.
availableNow	bool, volitelné	Pokud True, zpracuje všechna dostupná data v několika dávkách, ukončí dotaz.
realTime	str, volitelné	Řetězec dávkové doby trvání (například '5 seconds'). Spustí dotaz v režimu v reálném čase s dávkami v zadané době.

Návraty

DataStreamWriter

Příklady

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

Spuštění triggeru každých 5 sekund:

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

Aktivace průběžného spouštění každých 5 sekund:

:::Poznámka Bezserverová kompatibilita

trigger(continuous=) Nepodporuje se u výpočetních prostředků Bezserverové služby Databricks. Pro průběžné kanály v bezserverové podobě použijte místo toho průběžný režim kanálů Lakeflow .

:::

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

Zpracovat všechna dostupná data v několika dávkách:

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

Aktivace provádění v reálném čase každých 5 sekund:

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