name (StreamingQuery)

Returnerar det användardefinierade namnet på frågan, eller None om det inte har angetts. Ange via df.writeStream.queryName("query").start(). Om det anges måste det här namnet vara unikt för alla aktiva frågor.

Retur

str eller None

Exempel

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