id (StreamingQuery)

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

返品

str

例示

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