queryName (DataStreamWriter)

Specifica il nome di StreamingQuery che può essere avviato con start(). Questo nome deve essere univoco tra tutte le query attualmente attive nella sessione SparkSession associata.

Sintassi

queryName(queryName)

Parametri

Restituzioni

DataStreamWriter

Examples

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