PySparkリファレンスクラスストリーミングクエリステータスこのページの見出しステータス(ストリーミングクエリ) クエリの現在のステータスを返します。 戻り値 dict 例 Pythonsdf = spark.readStream.format("rate").load()sq = sdf.writeStream.format('memory').queryName('this_query').start()sq.status# {'message': '...', 'isDataAvailable': ..., 'isTriggerActive': ...}sq.stop()