awaitAnyTermination (StreamingQueryManager)

Menunggu hingga salah satu kueri pada yang terkait SparkSession telah dihentikan sejak pembuatan konteks, atau sejak resetTerminated() dipanggil. Jika ada kueri yang dihentikan dengan pengecualian, pengecualian akan dilemparkan. Jika timeout diatur, mengembalikan apakah ada kueri yang telah dihentikan dalam detik waktu habis.

Jika kueri telah dihentikan, panggilan berikutnya akan segera kembali (jika dihentikan secara normal) atau segera melemparkan pengecualian (jika dihentikan dengan pengecualian). Gunakan resetTerminated() untuk menghapus penghentian sebelumnya dan menunggu penghentian baru.

Sintaksis

awaitAnyTermination(timeout=None)

Parameter-parameternya

Parameter	Tipe	Deskripsi
timeout	int, opsional	Jumlah detik untuk menunggu. Jika tidak diatur, menunggu tanpa batas waktu.

Pengembalian Barang

bool atau None

Mengembalikan True atau False jika timeout diatur. Mengembalikan None jika tidak ada batas waktu yang ditetapkan.

Examples

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()