awaitTermination (StreamingQuery)

等待此查询的终止,由 stop() 异常或异常终止。 如果查询已终止并出现异常,将引发异常。 如果 timeout 已设置,则返回查询是否在超时秒内终止。

如果查询已终止,后续调用将立即返回(如果正常停止),或立即引发异常(如果终止并出现异常)。

Syntax

awaitTermination(timeout=None)

参数

参数 类型 Description
timeout int,可选 等待的秒数。 如果未设置,则无限期等待。

退货

boolNone

返回 TrueFalse 是否 timeout 设置,指示查询是否在超时范围内终止。 如果未设置超时,则返回 None

示例

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