queryName (DataStreamWriter)

Spécifie le nom de la StreamingQuery qui peut être start avec start(). Ce nom doit être unique parmi toutes les queries actives dans la SparkSession associée.

Syntaxe

queryName(queryName)

parameter

parameter	Type	Description
queryName	str	Nom unique pour la query.

parameter	Type	Description
queryName	str	Nom unique pour la query.

Renvoie

DataStreamWriter

Exemples

Python

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