nome (StreamingQuery)

Retorna o nome da consulta especificado pelo usuário ou None se não for especificado. Definido via df.writeStream.queryName("query").start(). Se definido, esse nome deve ser exclusivo em todas as consultas ativas.

Devoluções

str ou None

Exemplos

Python

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