queryName (DataStreamWriter)

Указывает имя StreamingQuery, с которыми можно начать start()работу. Это имя должно быть уникальным среди всех активных запросов в связанном SparkSession.

Синтаксис

queryName(queryName)

Параметры

Параметр	Тип	Описание
queryName	str	Уникальное имя запроса.

Возвраты

DataStreamWriter

Примеры

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