queryName (DataStreamWriter)

Especifica o nome da StreamingQuery que pode começar com start(). Esse nome deve ser único entre todas as consultas atualmente ativas na SparkSession associada.

Sintaxe

queryName(queryName)

Parâmetros

Parâmetro	Tipo	Descrição
queryName	str	Nome único para a consulta.

Devoluções

DataStreamWriter

Exemplos

Python

import time
df = spark.readStream.format("rate").load()
q = df.writeStream.queryName("streaming_query").format("console").start()
q.stop()
q.name
# 'streaming_query'