名稱(StreamingQuery)

回傳使用者指定的查詢名稱,若 None 未指定則為 透過 df.writeStream.queryName("query").start()設定 。 若設定為此名稱,必須在所有活躍查詢中保持唯一。

退貨

strNone

Examples

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.name
# 'this_query'
sq.stop()