queryName (DataStreamWriter)

Hiermee geeft u de naam van de StreamingQuery waarmee kan worden gestart start(). Deze naam moet uniek zijn voor alle momenteel actieve query's in de bijbehorende SparkSession.

Syntaxis

queryName(queryName)

Parameterwaarden

Kenmerk	Typ	Beschrijving
queryName	str	Unieke naam voor de query.

Retouren

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'