awaitAnyTermination (StreamingQueryManager)

コンテキストの作成以降、またはresetTerminated()が呼び出されてから、関連付けられたSparkSessionに対するクエリのいずれかが終了するまで待機します。クエリが例外で終了した場合、その例外がスローされます。timeoutが設定されている場合、タイムアウト秒数内にクエリが終了したかどうかを返します。

クエリが既に終了している場合、後続の呼び出しは、正常に停止した場合はすぐに戻り、例外で終了した場合はすぐ例外をスローします。過去の終了処理をクリアして新しい終了処理を待つには、 resetTerminated()使用してください。

構文

awaitAnyTermination(timeout=None)

パラメーター

パラメーター	Type	説明
timeout	整数、オプション	待機する秒数。設定されていない場合は、無期限に待機します。

戻り値

bool または None

timeout設定されている場合はTrue 、設定されている場合はFalseを返します。タイムアウトが設定されていない場合はNoneを返します。

例

Python

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()