queryName (DataStreamWriter)

Especifica el nombre de streamingQuery que se puede iniciar con start(). Este nombre debe ser único entre todas las consultas activas actualmente en sparkSession asociadas.

Sintaxis

queryName(queryName)

Parámetros

Parámetro	Tipo	Descripción
queryName	str	Nombre único de la consulta.

Devoluciones

DataStreamWriter

Ejemplos

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