Nom (StreamingQuery)

Renvoie le nom de la query spécifié par l'utilisateur, ou None si non spécifié. Défini via df.writeStream.queryName("query").start(). Si défini, ce nom doit être unique parmi toutes les requêtes actives.

Renvoie

str OU None

Exemples

Python

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