awaitTermination (StreamingQuery)

等待此查詢的終止,無論是透過 stop() 例外還是例外方式。 如果查詢以例外終止,該例外會被拋出。 若 timeout 設定為 ,則回傳查詢是否在逾時秒內終止。

如果查詢已經終止,後續呼叫要麼立即回傳(若正常停止),要麼立即拋出異常(若終止時有例外)。

語法

awaitTermination(timeout=None)

參數

參數 類型 說明
timeout int,可選 等待的時間。 如果沒設定,則無限期等待。

退貨

boolNone

Returns TrueFalse 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()