resetTerminated (StreamingQueryManager)

Забывает прошлые завершенные запросы, чтобы awaitAnyTermination() его можно было использовать еще раз, чтобы ждать новых завершения.

Синтаксис

resetTerminated()

Возвраты

None

Примеры

spark.streams.resetTerminated()