Name (StreamingQuery)

Gibt den vom Benutzer angegebenen Namen der Abfrage zurück oder None wenn nicht angegeben. Set via df.writeStream.queryName("query").start(). Wenn dieser Name festgelegt ist, muss dieser Name für alle aktiven Abfragen eindeutig sein.

Rückkehr

str oder None

Beispiele

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