等待关联 SparkSession 查询的任何查询自创建上下文后终止，或自调用以来 resetTerminated() 。 如果任何查询以异常终止，将引发异常。 如果 timeout 已设置，则返回是否在超时秒内终止任何查询。
如果查询已终止，后续调用将立即返回（如果正常停止）或立即引发异常（如果以异常终止）。 用于 resetTerminated() 清除过去的终止并等待新终止。
Syntax
awaitAnyTermination(timeout=None)
参数
| 参数 | 类型 | Description |
|---|---|---|
timeout |
int，可选 | 等待的秒数。 如果未设置，则无限期等待。 |
退货
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()