pyspark.sql.streaming.DataStreamWriter.queryName

DataStreamWriter.queryName(queryName)

Specifies the name of the StreamingQuery that can be started with start(). This name must be unique among all the currently active queries in the associated SparkSession.

Note

Evolving.

Parameters

queryName – unique name for the query

>>> writer = sdf.writeStream.queryName('streaming_query')

New in version 2.0.

pyspark.sql.streaming.DataStreamWriter.partitionBy pyspark.sql.streaming.DataStreamWriter.start