tetikleyici (DataStreamWriter)

Akış sorgusu için tetikleyiciyi ayarlar. Ayarlanmazsa, sorgu mümkün olduğunca hızlı çalışır ve ile eşdeğerdir processingTime='0 seconds'. Aynı anda yalnızca bir tetikleyici parametresi ayarlanabilir.

Daha fazla bilgi için bkz. Yapılandırılmış Akış tetikleyici aralıklarını yapılandırma.

Sözdizimi

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

Parametreler

Parametre	Türü	Açıklama
processingTime	str, isteğe bağlı	İşleme zaman aralığı dizesi (örneğin, , '5 seconds''1 minute'). İşleme süresine göre düzenli aralıklarla bir mikrobatch sorgusu çalıştırır.
once	bool, isteğe bağlı	ise True, yalnızca bir veri toplu işlemini işler ve sorguyu sonlandırır.
continuous	str, isteğe bağlı	Bir zaman aralığı dizesi (örneğin, '5 seconds'). Belirli bir denetim noktası aralığıyla sürekli sorgu çalıştırır.
availableNow	bool, isteğe bağlı	ise True, tüm kullanılabilir verileri birden çok toplu işte işler ve sorguyu sonlandırır.
realTime	str, isteğe bağlı	Bir toplu iş süresi dizesi (örneğin, '5 seconds'). Belirtilen süre boyunca toplu işlerle gerçek zamanlı mod sorgusu çalıştırır. Bakınız Yapılandırılmış Akış'ta Gerçek Zamanlı Mod.

İadeler

DataStreamWriter

Örnekler

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

Yürütmeyi her 5 saniyede bir tetikleme:

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

Her 5 saniyede bir sürekli yürütme tetikleme:

:::note Sunucusuz uyumluluk

trigger(continuous=) Databricks Sunucusuz işlemde desteklenmez. Sunucusuz üzerinde sürekli işlem hatları için bunun yerine Lakeflow işlem hatları sürekli modunu kullanın.

:::

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

Tüm kullanılabilir verileri birden çok toplu işte işleyin:

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

5 saniyede bir gerçek zamanlı yürütme tetikleme:

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