id (StreamingQuery)

Devuelve el identificador único de esta consulta que persiste en los reinicios de los datos de punto de control. El identificador se genera cuando se inicia una consulta por primera vez y es la misma cada vez que se reinicia desde los datos del punto de control. Solo puede haber una consulta con el mismo identificador activo en un clúster de Spark.

Devoluciones

str

Ejemplos

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