Freigeben über


resetTerminated (StreamingQueryManager)

Vergessen Sie vergangene beendete Abfragen, awaitAnyTermination() damit sie erneut verwendet werden können, um auf neue Beendigungen zu warten.

Syntax

resetTerminated()

Rückkehr

None

Beispiele

spark.streams.resetTerminated()