awaitTermination (StreamingQuery)

Czeka na zakończenie tego zapytania przez stop() wyjątek lub przez wyjątek. Jeśli zapytanie zostało zakończone z wyjątkiem, wyjątek zostanie zgłoszony. Jeśli timeout wartość jest ustawiona, zwraca informację, czy 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).

Składnia

awaitTermination(timeout=None)

Parametry

Parameter	Typ	Opis
timeout	int, opcjonalnie	Liczba sekund oczekiwania. Jeśli nie zostanie ustawiona, czeka na czas nieokreślony.

Zwroty

bool lub None

Zwraca True wartość lub False jeśli timeout jest ustawiona, wskazując, czy zapytanie zostało zakończone w przedziale czasu. Zwraca wartość None , jeśli nie ustawiono limitu czasu.

Examples

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