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

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'