pyspark.sql.streaming.StreamingQuery.awaitTermination

StreamingQuery。 awaitTermination ( 超時:可選(int]=沒有一個 )→可選(bool]

等待終止這查詢,通過query.stop ()或者是一個例外。如果查詢終止了一個異常,那麼就會拋出異常。如果超時設置,它返回查詢是否已經終止或不超時秒。

如果查詢已終止,那麼所有後續對這個方法的調用會立即返回(如果查詢被終止stop ()),或者立即拋出的異常(如果查詢已終止,例外)。

拋出StreamingQueryException,如果這查詢與異常終止

以前的

查詢管理

下一個

pyspark.sql.streaming.StreamingQuery.exception