Nota
L-aċċess għal din il-paġna jeħtieġ l-awtorizzazzjoni. Tista’ tipprova tidħol jew tibdel id-direttorji.
L-aċċess għal din il-paġna jeħtieġ l-awtorizzazzjoni. Tista’ tipprova tibdel id-direttorji.
Specifies the name of the StreamingQuery that can be started with start(). This name must be unique among all currently active queries in the associated SparkSession.
Syntax
queryName(queryName)
Parameters
| Parameter | Type | Description |
|---|---|---|
queryName |
str | Unique name for the query. |
Returns
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'