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 eine aktive Streamingabfrage daraus SparkSession anhand ihrer eindeutigen ID zurück.
Syntax
get(id)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
id |
str | Die eindeutige ID der Abfrage. |
Rückkehr
StreamingQuery
Hinweise
Eine Ausnahme wird ausgelöst, wenn keine aktive Abfrage mit der angegebenen ID vorhanden ist.
Beispiele
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq = spark.streams.get(sq.id)
sq.isActive
# True
sq.stop()