awaitAnyTermination (StreamingQueryManager)

Czeka na zakończenie któregokolwiek z zapytań skojarzonych SparkSession od momentu utworzenia kontekstu lub od resetTerminated() tego czasu. Jeśli jakiekolwiek zapytanie zostało zakończone z wyjątkiem, zostanie zgłoszony wyjątek. Jeśli timeout wartość jest ustawiona, zwraca informację, czy jakiekolwiek zapytanie zostało zakończone w ciągu kilku sekund.

Jeśli zapytanie zostało już zakończone, kolejne wywołania zwracają natychmiast (jeśli zatrzymano normalnie) lub natychmiast zgłaszają wyjątek (jeśli zostanie zakończony z wyjątkiem). Użyj resetTerminated() polecenia , aby wyczyścić wcześniejsze zakończenia i poczekać na nowe.

Składnia

awaitAnyTermination(timeout=None)

Parametry

Zwroty

bool lub None

Zwraca wartość True lub False wartość timeout ustawioną. Zwraca wartość None , jeśli nie ustawiono limitu czasu.

Examples

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