id (StreamingQuery)

Retourne l’ID unique de cette requête qui persiste entre les redémarrages à partir des données de point de contrôle. L’ID est généré lorsqu’une requête est démarrée pour la première fois et est la 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 requête avec le même ID actif dans un cluster Spark.

Retours

str

Exemples

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