name (StreamingQuery)

Sorgunun kullanıcı tarafından belirtilen adını veya None belirtilmemişse döndürür. aracılığıyla df.writeStream.queryName("query").start()ayarlayın. Ayarlanırsa, bu ad tüm etkin sorgularda benzersiz olmalıdır.

İadeler

str veya None

Örnekler

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