컨텍스트를 만든 이후 또는 SparkSession 호출된 resetTerminated() 이후 연결된 쿼리가 종료될 때까지 기다립니다. 예외로 종료된 쿼리가 있으면 예외가 throw됩니다. 설정된 경우 timeout 제한 시간(초) 내에 쿼리가 종료되었는지 여부를 반환합니다.
쿼리가 이미 종료된 경우 후속 호출은 즉시 반환하거나(정상적으로 중지된 경우) 예외를 즉시 throw합니다(예외로 종료된 경우). 과거의 종료를 지우고 새 종료를 기다리는 데 사용합니다 resetTerminated() .
문법
awaitAnyTermination(timeout=None)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
timeout |
int, 선택 사항 | 대기할 시간(초)입니다. 설정하지 않으면 무기한 대기합니다. |
Returns
bool 또는 None
반환 True 하거나 False 설정된 경우 timeout 시간 제한이 설정되지 않은 경우 반환 None 합니다.
예제
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()