awaitTermination (StreamingQuery)

Espera la finalización de esta consulta, ya sea por stop() o por una excepción. Si la consulta ha finalizado con una excepción, se producirá la excepción. Si timeout se establece, devuelve si la consulta ha finalizado en los segundos de tiempo de espera.

Si la 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).

Sintaxis

awaitTermination(timeout=None)

Parámetros

Devoluciones

bool o None

Devuelve True o False si timeout se establece, lo que indica si la consulta finalizó dentro del tiempo de espera. Devuelve None si no se establece ningún tiempo de espera.

Ejemplos

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