resetTerminated (StreamingQueryManager)

Oublie les requêtes terminées passées afin que awaitAnyTermination() puisse être utilisé à nouveau pour attendre de nouvelles terminaisons.

Syntaxe

resetTerminated()

Renvoie

None

Exemples

Python

spark.streams.resetTerminated()