id (StreamingQuery)

Retorna o ID exclusivo desta consulta, que persiste entre reinicializações a partir dos dados do ponto de verificação. O ID é gerado quando uma consulta é iniciada pela primeira vez e é o mesmo sempre que ela é reiniciada a partir dos dados do ponto de verificação. Em um cluster Spark, só pode haver uma consulta com o mesmo ID ativa.

Devoluções

str

Exemplos

Python

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