queryName (DataStreamWriter)

Specifies the name of the StreamingQuery that can be started with start(). This name must be unique among all currently active queries in the associated SparkSession.

Syntax

queryName(queryName)

Parameters

Parameter	Type	Description
queryName	str	Unique name for the query.

Returns

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'