We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8eac465 commit 564dbf6Copy full SHA for 564dbf6
docs/structured-streaming-programming-guide.md
@@ -2310,11 +2310,11 @@ spark.streams().awaitAnyTermination(); // block until any one of them terminat
2310
{% highlight python %}
2311
spark = ... # spark session
2312
2313
-spark.streams().active # get the list of currently active streaming queries
+spark.streams.active # get the list of currently active streaming queries
2314
2315
-spark.streams().get(id) # get a query object by its unique id
+spark.streams.get(id) # get a query object by its unique id
2316
2317
-spark.streams().awaitAnyTermination() # block until any one of them terminates
+spark.streams.awaitAnyTermination() # block until any one of them terminates
2318
{% endhighlight %}
2319
2320
</div>
0 commit comments