メインコンテンツまでスキップ

名前(ストリーミングクエリ)

ユーザーが指定したクエリ名を返します。指定されていない場合はNone返します。df.writeStream.queryName("query").start()で設定します。設定する場合、この名前はすべてのアクティブなクエリで一意である必要があります。

戻り値

str または None

Python
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.name
# 'this_query'
sq.stop()
このページの見出し