queryName (DataStreamWriter)

Určuje název StreamQuery, se kterým lze začít start(). Tento název musí být jedinečný mezi všemi aktuálně aktivními dotazy v přidružené SparkSession.

Syntaxe

queryName(queryName)

Parametry

Parameter	Typ	Description
queryName	str	Jedinečný název dotazu.

Návraty

DataStreamWriter

Příklady

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