runId (StreamingQuery)

Devuelve el identificador único de esta consulta que no persiste en los reinicios. Cada consulta que se inicia (o se reinicia desde el punto de control) tendrá un valor diferente runId.

Devoluciones

str

Ejemplos

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