ID (StreamingQuery)

Vrátí jedinečné ID tohoto dotazu, které se zachová napříč restartováními z dat kontrolního bodu. ID se vygeneruje při prvním spuštění dotazu a je stejné při každém restartování z dat kontrolního bodu. V clusteru Spark může být jenom jeden dotaz se stejným ID.

Návraty

str

Příklady

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