awaitAnyTermination (StreamingQueryManager)

Espera até que qualquer uma das consultas no associado SparkSession tenha terminado desde a criação do contexto, ou desde resetTerminated() que foi chamada. Se alguma consulta terminar com uma exceção, a exceção será lançada. Se timeout for definido, retorna se alguma consulta terminou dentro dos segundos de timeout.

Se uma consulta já tiver terminado, as chamadas subsequentes retornam imediatamente (se normalmente paradas) ou lançam a exceção imediatamente (se terminadas com uma exceção). Uso resetTerminated() para resolver terminações anteriores e esperar por novas.

Sintaxe

awaitAnyTermination(timeout=None)

Parâmetros

Devoluções

bool ou None

Devolve True ou False se timeout está definido. Devolve None se não houver tempo limite definido.

Exemplos

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