awaitTermination (StreamingQuery)

Aguarda a terminação desta consulta, seja por stop() ou por exceção. Se a consulta terminar com uma exceção, a exceção será lançada. Se timeout for definido, devolve se a consulta terminou dentro dos segundos de timeout.

Se a 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).

Sintaxe

awaitTermination(timeout=None)

Parâmetros

Devoluções

bool ou None

Retorna True ou False se timeout for definido, indicando se a consulta terminou dentro do timeout. Devolve None se não houver tempo limite definido.

Exemplos

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()