runId(StreamingQuery)

回傳此查詢的唯一 ID,且不會在多次重啟後持續存在。 每次從檢查點開始(或重新啟動)的查詢都會有不同的 runId

退貨

str

Examples

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