id (StreamingQuery)

チェックポイントデータから、再起動後も保持されるこのクエリの一意のIDを返します。IDはクエリが初めて開始されたときに生成され、チェックポイントデータから再開されるたびに同じものになります。Sparkループでは、同じ ID を持つクエリは 1 つしかアクティブにできません。

戻り値

str

例

Python

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