PySparkリファレンスクラスストリーミングクエリランIDこのページの見出しrunId (StreamingQuery) 再起動後も保持されない、このクエリの一意のIDを返します。開始された(またはチェックポイントから再開された)すべてのクエリには、異なるrunIdが割り当てられます。 戻り値 str 例 Pythonsdf = spark.readStream.format("rate").load()sq = sdf.writeStream.format('memory').queryName('this_query').start()sq.runId# '...'sq.stop()