awaitAnyTermination (StreamingQueryManager)

Attende fino a quando una qualsiasi delle query sull'oggetto associato SparkSession è stata terminata dopo la creazione del contesto o dopo resetTerminated() la chiamata. Se una query terminata con un'eccezione, verrà generata l'eccezione. Se timeout è impostato, restituisce se una query è stata terminata entro i secondi di timeout.

Se una query è già stata terminata, le chiamate successive restituiscono immediatamente (se arrestate normalmente) o generano immediatamente l'eccezione (se terminata con un'eccezione). Usare resetTerminated() per cancellare le terminazioni passate e attendere le nuove terminazioni.

Sintassi

awaitAnyTermination(timeout=None)

Parametri

Restituzioni

bool oppure None

Restituisce True o False se timeout è impostato. Restituisce None se non è impostato alcun timeout.

Examples

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