runId (StreamingQuery)

Devolve o ID único desta consulta que não persiste em reinícios. Cada consulta iniciada (ou reiniciada a partir do checkpoint) terá um .runId

Devoluções

str

Exemplos

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