name (StreamingQuery)

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

Devoluções

str ou None

Exemplos

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