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.

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:

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 ...>