This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.2 by this push:
new a477f85 [MINOR][DOC] Fix documentation for structured streaming -
addListener
a477f85 is described below
commit a477f85a41294d5ab10fe3d72ce21cdc00df304e
Author: Karthik Subramanian <[email protected]>
AuthorDate: Fri Feb 18 12:52:11 2022 +0900
[MINOR][DOC] Fix documentation for structured streaming - addListener
### What changes were proposed in this pull request?
This PR fixes the incorrect documentation in Structured Streaming Guide
where it says `sparkSession.streams.attachListener()` instead of
`sparkSession.streams.addListener()` which is the correct usage as mentioned in
the code snippet below in the same doc.
### Why are the changes needed?
The documentation was erroneous, and needs to be fixed to avoid confusion
by readers
### Does this PR introduce _any_ user-facing change?
Yes, since it's a doc fix. This fix needs to be applied to previous
versions retro-actively as well.
### How was this patch tested?
Not necessary
Closes #35562 from yeskarthik/fix-structured-streaming-docs-1.
Authored-by: Karthik Subramanian <[email protected]>
Signed-off-by: Hyukjin Kwon <[email protected]>
(cherry picked from commit 837248a0c42d55ad48240647d503ad544e64f016)
Signed-off-by: Hyukjin Kwon <[email protected]>
---
docs/structured-streaming-programming-guide.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/structured-streaming-programming-guide.md
b/docs/structured-streaming-programming-guide.md
index 047340d..23c2e70 100644
--- a/docs/structured-streaming-programming-guide.md
+++ b/docs/structured-streaming-programming-guide.md
@@ -3264,7 +3264,7 @@ You can also asynchronously monitor all queries
associated with a
`SparkSession` by attaching a `StreamingQueryListener`
([Scala](api/scala/org/apache/spark/sql/streaming/StreamingQueryListener.html)/[Java](api/java/org/apache/spark/sql/streaming/StreamingQueryListener.html)
docs).
Once you attach your custom `StreamingQueryListener` object with
-`sparkSession.streams.attachListener()`, you will get callbacks when a query
is started and
+`sparkSession.streams.addListener()`, you will get callbacks when a query is
started and
stopped and when there is progress made in an active query. Here is an example,
<div class="codetabs">
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
