pyspark.sql.streaming.StreamingQueryManager.resetTerminated

StreamingQueryManager.resetTerminated() → None

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

Examples

>>> spark.streams.resetTerminated()

previous

pyspark.sql.streaming.StreamingQueryManager.removeListener

next

MLlib (DataFrame-based)