resetTerminated (StreamingQueryManager)

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

Syntax

resetTerminated()

Returns

None

Examples

spark.streams.resetTerminated()