resetTerminated (StreamingQueryManager)

過去に終了したクエリを破棄し、 awaitAnyTermination()再度使用して新しい終了を待つことができるようにします。

構文

resetTerminated()

戻り値

None

例

Python

spark.streams.resetTerminated()