nome (StreamingQuery)

Devolve o nome especificado pelo utilizador da consulta, ou None se não for especificado. Definido via df.writeStream.queryName("query").start(). Se definido, este nome deve ser único 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()