Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Gibt den Namen der StreamingQuery an, mit der gestartet start()werden kann. Dieser Name muss für alle aktuell aktiven Abfragen in der zugeordneten SparkSession eindeutig sein.
Syntax
queryName(queryName)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
queryName |
str | Eindeutiger Name für die Abfrage. |
Rückkehr
DataStreamWriter
Beispiele
import time
df = spark.readStream.format("rate").load()
q = df.writeStream.queryName("streaming_query").format("console").start()
q.stop()
q.name
# 'streaming_query'