name (StreamingQuery)

Retourne le nom spécifié par l’utilisateur de la requête, ou None s’il n’est pas spécifié. Définir via df.writeStream.queryName("query").start(). Si cette valeur est définie, ce nom doit être unique dans toutes les requêtes actives.

Retours

str ou None

Exemples

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