QueryName (DataStreamWriter)

Especifica o nome do StreamingQuery que pode ser iniciado com start(). Este nome deve ser único entre todas as consultas atualmente ativas na SparkSession associada.

Sintaxe

queryName(queryName)

Parâmetros

Devoluções

DataStreamWriter

Exemplos

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