naam (StreamingQuery)

Retourneert de door de gebruiker opgegeven naam van de query of None als deze niet is opgegeven. Instellen via df.writeStream.queryName("query").start(). Als deze naam is ingesteld, moet deze naam uniek zijn voor alle actieve query's.

Retouren

str of None

Examples

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