pyspark.sql.streaming.StreamingQueryManager.awaitAnyTermination¶
-
StreamingQueryManager。awaitAnyTermination( 超時:可選(int]=沒有一個 )→可選(bool] ¶ -
等到任何的查詢相關SQLContext終止自創建上下文,或自
resetTerminated ()被稱為。如果任何查詢終止了一個異常,那麼就會拋出異常。如果超時設置,它返回查詢是否已經終止或不超時秒。如果一個查詢已終止,那麼隨後的調用
awaitAnyTermination ()要麼立即返回(如果查詢終止了嗎query.stop ()),或者立即拋出的異常(如果查詢是終止例外)。使用resetTerminated ()清除過去的終端,等待新的終端。如果多個查詢後終止
resetTermination ()叫,如果任何查詢與異常終止,然後呢awaitAnyTermination ()將拋出的任何異常。對於正確記錄異常跨多個查詢,用戶需要停止他們其中任何一個終止後異常,然後檢查query.exception ()為每個查詢。拋出
StreamingQueryException,如果這查詢與異常終止