queryName (DataStreamWriter)

Especifica o nome do StreamingQuery que pode ser iniciado com start(). Esse nome deve ser exclusivo entre todas as consultas ativas no momento no SparkSession associado.

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'