awaitAnyTermination (StreamingQueryManager)

Espera hasta que se haya terminado cualquiera de las consultas del asociado SparkSession desde la creación del contexto o desde que resetTerminated() se llamó a . Si alguna consulta finaliza con una excepción, se producirá la excepción. Si timeout se establece, devuelve si alguna consulta ha finalizado en los segundos de tiempo de espera.

Si una consulta ya ha finalizado, las llamadas posteriores devuelven inmediatamente (si se detienen normalmente) o inician la excepción inmediatamente (si finalizan con una excepción). Use resetTerminated() para borrar las finalizaciones pasadas y esperar a las nuevas.

Sintaxis

awaitAnyTermination(timeout=None)

Parámetros

Devoluciones

bool o None

Devuelve True o False si timeout se establece. Devuelve None si no se establece ningún tiempo de espera.

Ejemplos

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