queryName (DataStreamWriter)

Określa nazwę zapytania przesyłania strumieniowego, który można uruchomić za pomocą start()polecenia . Ta nazwa musi być unikatowa wśród wszystkich aktualnie aktywnych zapytań w skojarzonej usłudze SparkSession.

Składnia

queryName(queryName)

Parametry

Parameter	Typ	Opis
queryName	str	Unikatowa nazwa zapytania.

Zwroty

DataStreamWriter

Examples

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