pyspark.sql.streaming.StreamingQueryManager.resetTerminated

StreamingQueryManager。 resetTerminated ( )→沒有

忘記過去的終止,以便查詢awaitAnyTermination ()可以再次等待新終端使用。

例子

> > >火花resetTerminated()