pemicu (DataStreamWriter)

Mengatur pemicu untuk kueri streaming. Jika tidak diatur, kueri berjalan secepat mungkin, setara dengan processingTime='0 seconds'. Hanya satu parameter pemicu yang dapat diatur pada satu waktu.

Untuk informasi selengkapnya, lihat Mengonfigurasi interval pemicu Streaming Terstruktur.

Sintaksis

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

Parameter-parameternya

Parameter	Tipe	Deskripsi
processingTime	str, opsional	String interval waktu pemrosesan (misalnya, '5 seconds', '1 minute'). Menjalankan kueri microbatch secara berkala berdasarkan waktu pemrosesan.
once	bool, opsional	Jika True, hanya memproses satu batch data, maka mengakhiri kueri.
continuous	str, opsional	String interval waktu (misalnya, '5 seconds'). Menjalankan kueri berkelanjutan dengan interval titik pemeriksaan tertentu.
availableNow	bool, opsional	Jika True, memproses semua data yang tersedia dalam beberapa batch, maka mengakhiri kueri.
realTime	str, opsional	String durasi batch (misalnya, '5 seconds'). Menjalankan kueri mode real time dengan batch pada durasi yang ditentukan. Lihat Mode real time di Streaming Terstruktur.

Pengembalian Barang

DataStreamWriter

Examples

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

Eksekusi pemicu setiap 5 detik:

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

Picu eksekusi berkelanjutan setiap 5 detik:

:::note Kompatibilitas tanpa server

trigger(continuous=) tidak didukung pada komputasi Tanpa Server Databricks. Untuk alur berkelanjutan pada tanpa server, gunakan mode berkelanjutan alur Lakeflow .

:::

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

Proses semua data yang tersedia dalam beberapa batch:

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

Picu eksekusi real time setiap 5 detik:

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