runId (StreamingQuery)

Vrátí jedinečné ID tohoto dotazu, které se nezachovává při restartování. Každý spuštěný dotaz (nebo restartovaný z kontrolního bodu) bude mít jiný runId.

Návraty

str

Příklady

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