aguardar qualquer término (Gerenciador de consultas de streaming)

Aguarda até que qualquer uma das consultas no SparkSession associado tenha terminado desde a criação do contexto ou desde que resetTerminated() foi chamado. Se alguma consulta terminar com uma exceção, essa exceção será lançada. Se timeout estiver definido, retorna se alguma consulta foi encerrada dentro do tempo limite em segundos.

Se uma consulta já tiver sido finalizada, as chamadas subsequentes retornarão imediatamente (se forem interrompidas normalmente) ou lançarão a exceção imediatamente (se forem finalizadas com uma exceção). Use resetTerminated() para limpar encerramentos anteriores e aguardar novos.

Sintaxe

awaitAnyTermination(timeout=None)

Parâmetros

Parâmetro	Tipo	Descrição
timeout	int, opcional	O número de segundos a esperar. Se não estiver configurado, aguarda indefinidamente.

Devoluções

bool ou None

Retorna True ou False se timeout estiver definido. Retorna None se nenhum tempo limite for definido.

Exemplos

Python

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()