等待此查詢的終止,無論是透過 stop() 例外還是例外方式。 如果查詢以例外終止,該例外會被拋出。 若 timeout 設定為 ,則回傳查詢是否在逾時秒內終止。
如果查詢已經終止,後續呼叫要麼立即回傳(若正常停止),要麼立即拋出異常(若終止時有例外)。
語法
awaitTermination(timeout=None)
參數
| 參數 | 類型 | 說明 |
|---|---|---|
timeout |
int,可選 | 等待的時間。 如果沒設定,則無限期等待。 |
退貨
bool 或 None
Returns True 或 False if timeout 是設定的,表示查詢是否在逾時內終止。 若未設定超時,則返回 None 。
Examples
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()