queryName (DataStreamWriter)

Anger namnet på StreamingQuery som kan startas med start(). Det här namnet måste vara unikt bland alla aktiva frågor i den associerade SparkSession.

Syntax

queryName(queryName)

Parameters

Retur

DataStreamWriter

Exempel

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