等待直到關聯上的任何查詢 SparkSession 自上下文建立 resetTerminated() 或被呼叫以來都終止。 若任何查詢以例外終止，該例外將被拋出。 若 timeout 設定 ，則回傳任何查詢是否在逾時秒內終止。
如果查詢已經終止，後續呼叫要麼立即回傳（若正常停止），要麼立即拋出異常（若終止時有例外）。 用 resetTerminated() 來清除過去的終止並等待新的。
語法
awaitAnyTermination(timeout=None)
參數
| 參數 | 類型 | 說明 |
|---|---|---|
timeout |
int，可選 | 等待的時間。 如果沒設定，則無限期等待。 |
退貨
bool 或 None
退貨 True 或 False 是否 timeout 已設定。 若未設定超時，則返回 None 。
Examples
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()