id (StreamingQuery)

Devolve o ID único desta consulta que persiste em reinicios a partir dos dados do ponto de controlo. O ID é gerado quando uma consulta é iniciada pela primeira vez, e é o mesmo sempre que é reiniciado a partir dos dados do checkpoint. Só pode haver uma consulta com o mesmo ID ativa num cluster Spark.

Devoluções

str

Exemplos

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