等待此查询的终止,由 stop() 异常或异常终止。 如果查询已终止并出现异常,将引发异常。 如果 timeout 已设置,则返回查询是否在超时秒内终止。
如果查询已终止,后续调用将立即返回(如果正常停止),或立即引发异常(如果终止并出现异常)。
Syntax
awaitTermination(timeout=None)
参数
| 参数 | 类型 | Description |
|---|---|---|
timeout |
int,可选 | 等待的秒数。 如果未设置,则无限期等待。 |
退货
bool 或 None
返回 True 或 False 是否 timeout 设置,指示查询是否在超时范围内终止。 如果未设置超时,则返回 None 。
示例
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()