awaitAnyTermination (StreamingQueryManager)

Aguarda até que qualquer uma das consultas associadas SparkSession seja encerrada desde a criação do contexto ou desde que resetTerminated() foi chamada. Se qualquer consulta for encerrada com uma exceção, a exceção será gerada. Se timeout estiver definido, retornará se qualquer consulta foi encerrada nos segundos limite.

Se uma consulta já tiver sido encerrada, as chamadas subsequentes retornarão imediatamente (se interrompidas normalmente) ou lançarão a exceção imediatamente (se terminar com uma exceção). Use resetTerminated() para limpar terminações passadas e aguardar por novas.

Sintaxe

awaitAnyTermination(timeout=None)

Parâmetros

Devoluções

bool ou None

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

Exemplos

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