pyspark.sql.streaming.StreamingQueryManager.resetTerminated¶
-
StreamingQueryManager。
resetTerminated
( )→沒有¶ -
忘記過去的終止,以便查詢
awaitAnyTermination ()
可以再次等待新終端使用。例子
> > >火花。流。resetTerminated()
StreamingQueryManager。
resetTerminated
(
)→沒有¶
忘記過去的終止,以便查詢awaitAnyTermination ()
可以再次等待新終端使用。
例子
> > >火花。流。resetTerminated()