awaitTermination (StreamingQuery)

Menunggu penghentian kueri ini, baik menurut stop() atau dengan pengecualian. Jika kueri telah dihentikan dengan pengecualian, pengecualian akan dilemparkan. Jika timeout diatur, mengembalikan apakah kueri telah dihentikan dalam detik waktu habis.

Jika kueri telah dihentikan, panggilan berikutnya segera kembali (jika dihentikan secara normal) atau segera melemparkan pengecualian (jika dihentikan dengan pengecualian).

Sintaksis

awaitTermination(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

True Mengembalikan atau False jika timeout diatur, menunjukkan apakah kueri dihentikan dalam batas waktu. Mengembalikan None jika tidak ada batas waktu yang ditetapkan.

Examples

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()