queryName (DataStreamWriter)

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

構文

queryName(queryName)

パラメーター

返品

DataStreamWriter

例示

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