pyspark.sql.streaming.StreamingQueryManager.resetTerminated

StreamingQueryManager.resetTerminated()

Forget about past terminated queries so that awaitAnyTermination() can be used again to wait for new terminations.

New in version 2.0.0.

Examples

>>>

>>> spark.streams.resetTerminated()

pyspark.sql.streaming.StreamingQueryManager.get MLlib (DataFrame-based)