pyspark.sql.streaming.DataStreamWriter.queryName

DataStreamWriter。 queryName ( queryName:str )→pyspark.sql.streaming.readwriter.DataStreamWriter

指定的名稱StreamingQuery可以開始start ()。這個名稱必須是唯一的在所有的當前活動查詢SparkSession有關。

參數
queryName str

獨特的名稱查詢

筆記

這個API是不斷發展的。

例子

> > >作家=自衛隊writeStreamqueryName(“streaming_query”)