ID (StreamingQuery)

Renvoie l'ID unique de cette query qui persiste après les redémarrages à partir des données de point de contrôle. L'ID est généré lorsqu'une query est start pour la première fois, et est le même chaque fois qu'elle est redémarrée à partir des données de point de contrôle. Il ne peut y avoir qu'une seule query avec le même ID active dans un cluster Spark.

Renvoie

str

Exemples

Python

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