id (StreamingQuery)

Retourneert de unieke id van deze query die blijft bestaan tijdens het opnieuw opstarten van controlepuntgegevens. De id wordt gegenereerd wanneer een query voor het eerst wordt gestart en telkens wanneer deze opnieuw wordt opgestart vanuit controlepuntgegevens. Er kan slechts één query met dezelfde id actief zijn in een Spark-cluster.

Retouren

str

Examples

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