クエリ名 (DataStreamWriter)

start()で開始できる StreamingQuery の名前を指定します。この名前は、関連付けられた SparkSession 内の現在アクティブなすべてのクエリの中で一意である必要があります。

構文

queryName(queryName)

パラメーター

パラメーター	Type	説明
queryName	str	クエリの一意の名前。

戻り値

DataStreamWriter

例

Python

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