resetTerminated (Gerenciador de Consultas de Streaming)

Esquece consultas encerradas anteriormente para que awaitAnyTermination() possa ser usado novamente para aguardar novos encerramentos.

Sintaxe

resetTerminated()

Devoluções

None

Exemplos

Python

spark.streams.resetTerminated()