aguardar término (StreamingQuery)

Aguarda o término desta consulta, seja por stop() ou por uma exceção. Se a consulta terminar com uma exceção, essa exceção será lançada. Se timeout estiver definido, retorna se a consulta foi encerrada dentro do tempo limite em segundos.

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

Sintaxe

awaitTermination(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, indicando se a consulta terminou dentro do tempo limite. Retorna None se nenhum tempo limite for definido.

Exemplos

Python

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