Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Returnerar en aktiv direktuppspelningsfråga från detta SparkSession med dess unika ID.
Syntax
get(id)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
id |
str | Frågans unika ID. |
Retur
StreamingQuery
Notes
Ett undantag utlöses om en aktiv fråga med det angivna ID:t inte finns.
Exempel
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()