id（StreamingQuery）

回傳該查詢的唯一 ID，該 ID 會從檢查點資料持續執行。 ID 會在首次啟動查詢時產生，每次從檢查點資料重新啟動時都是相同的。 Spark 叢集中只能有一個相同 ID 的查詢在啟用。

退貨

str

Examples

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