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. Se Realtidsläge i Strukturerad direktuppspelning.

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:

:::obs Serverlös kompatibilitet

trigger(continuous=) stöds inte på databricks serverlös beräkning. För kontinuerliga pipelines på serverlösa använder du lakeflow-pipelines kontinuerligt läge i stället.

:::

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