This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from bac7050cf0a Revert "[SPARK-41811][PYTHON][CONNECT] Implement
SparkSession.sql's string formatter"
add fd518dac8d9 [SPARK-44201][CONNECT][SS] Add support for Streaming
Listener in Scala for Spark Connect
No new revisions were added by this update.
Summary of changes:
.../sql/streaming/StreamingQueryListener.scala | 132 ++++++++++++---------
.../sql/streaming/StreamingQueryManager.scala | 77 ++++++++++++
.../ui/StreamingQueryStatusListener.scala | 61 +++++-----
.../apache/spark/sql/streaming/ui/UIUtils.scala | 0
.../CheckConnectJvmClientCompatibility.scala | 27 +++--
.../spark/sql/streaming/StreamingQuerySuite.scala | 90 +++++++++++++-
.../src/main/protobuf/spark/connect/commands.proto | 21 ++++
...rPacket.scala => StreamingListenerPacket.scala} | 20 ++--
.../sql/connect/planner/SparkConnectPlanner.scala | 46 ++++++-
.../spark/sql/connect/service/SessionHolder.scala | 33 ++++++
python/pyspark/sql/connect/proto/commands_pb2.py | 42 ++++---
python/pyspark/sql/connect/proto/commands_pb2.pyi | 121 ++++++++++++++++++-
.../sql/streaming/StreamingQueryListener.scala | 13 +-
.../ui/StreamingQueryStatusListener.scala | 4 +-
14 files changed, 545 insertions(+), 142 deletions(-)
copy {sql/core =>
connector/connect/client/jvm}/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryListener.scala
(53%)
copy {sql/core =>
connector/connect/client/jvm}/src/main/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatusListener.scala
(84%)
copy {sql/core =>
connector/connect/client/jvm}/src/main/scala/org/apache/spark/sql/streaming/ui/UIUtils.scala
(100%)
copy
connector/connect/common/src/main/scala/org/apache/spark/sql/connect/common/{ForeachWriterPacket.scala
=> StreamingListenerPacket.scala} (66%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
