This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 47ac097f61c [SPARK-43207][CONNECT] Add helper functions to extract
value from literal expression
add 217876916cd [SPARK-43183][SS] Introduce a new callback "onQueryIdle"
to StreamingQueryListener
No new revisions were added by this update.
Summary of changes:
python/pyspark/sql/dataframe.py | 3 +
python/pyspark/sql/streaming/listener.py | 46 +++++++
python/pyspark/sql/streaming/query.py | 6 +
.../sql/tests/streaming/test_streaming_listener.py | 6 +
python/pyspark/sql/tests/test_dataframe.py | 3 +
.../org/apache/spark/sql/internal/SQLConf.scala | 2 +-
.../sql/execution/streaming/ProgressReporter.scala | 137 ++++++++++-----------
.../streaming/StreamingQueryListenerBus.scala | 4 +
.../sql/streaming/StreamingQueryListener.scala | 19 +++
.../ui/StreamingQueryStatusListener.scala | 2 +
.../sql/streaming/ReportSinkMetricsSuite.scala | 2 +
.../apache/spark/sql/streaming/StreamTest.scala | 1 +
.../streaming/StreamingQueryListenerSuite.scala | 52 ++++++--
.../StreamingQueryListenersConfSuite.scala | 4 +
.../StreamingQueryStatusAndProgressSuite.scala | 41 +-----
.../sql/hive/thriftserver/DummyListeners.scala | 1 +
16 files changed, 204 insertions(+), 125 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
