awaitTermination (StreamingQuery)

stop()による終了、または例外による終了のいずれかを待ちます。クエリが例外で終了した場合、その例外がスローされます。timeoutが設定されている場合、クエリがタイムアウト秒内に終了したかどうかを返します。

クエリが既に終了している場合、後続の呼び出しは、正常に停止した場合はすぐに戻り、例外で終了した場合はすぐ例外をスローします。

構文

awaitTermination(timeout=None)

パラメーター

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

戻り値

bool または None

timeoutが設定されている場合はTrue 、設定されている場合はFalseを返し、クエリがタイムアウト内に終了したかどうかを示します。タイムアウトが設定されていない場合はNoneを返します。

例

Python

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