From 02ec5a85fd0a7ecaa815f7fd91af22b146d025ae Mon Sep 17 00:00:00 2001 From: Peter Kaszt Date: Sat, 30 Sep 2023 17:17:44 +0200 Subject: [PATCH] Fix typos in structured-streaming-programming-guide.md Fix python language code sample for StreamingQueryListener: Reporting Metrics programmatically using Asynchronous APIs --- docs/structured-streaming-programming-guide.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md index 70e763be0d70..774422a9cd9d 100644 --- a/docs/structured-streaming-programming-guide.md +++ b/docs/structured-streaming-programming-guide.md @@ -3837,10 +3837,10 @@ class Listener(StreamingQueryListener): print("Query started: " + queryStarted.id) def onQueryProgress(self, event): - println("Query terminated: " + queryTerminated.id) + print("Query made progress: " + queryProgress.progress) def onQueryTerminated(self, event): - println("Query made progress: " + queryProgress.progress) + print("Query terminated: " + queryTerminated.id) spark.streams.addListener(Listener())