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

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'