This is an automated email from the ASF dual-hosted git repository.
xinrong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 8711c1a6ad9 [SPARK-42945][CONNECT][FOLLOW-UP] Add user_id and
session_id when logging errors
add 5cb7e6ffd91 [SPARK-43032][CONNECT][SS] Add Streaming query manager
No new revisions were added by this update.
Summary of changes:
.../src/main/protobuf/spark/connect/base.proto | 3 +
.../src/main/protobuf/spark/connect/commands.proto | 50 ++++-
.../sql/connect/planner/SparkConnectPlanner.scala | 76 ++++++-
.../sql/connect/service/SparkConnectService.scala | 8 +-
python/pyspark/sql/connect/client.py | 3 +
python/pyspark/sql/connect/proto/base_pb2.py | 124 ++++++------
python/pyspark/sql/connect/proto/base_pb2.pyi | 13 ++
python/pyspark/sql/connect/proto/commands_pb2.py | 210 +++++++++++++------
python/pyspark/sql/connect/proto/commands_pb2.pyi | 225 +++++++++++++++++++++
python/pyspark/sql/connect/session.py | 9 +-
python/pyspark/sql/connect/streaming/__init__.py | 1 +
python/pyspark/sql/connect/streaming/query.py | 87 +++++++-
python/pyspark/sql/connect/streaming/readwriter.py | 3 +-
.../connect/streaming/test_parity_streaming.py | 27 +--
.../sql/tests/connect/test_connect_basic.py | 1 -
.../test_parity_pandas_grouped_map_with_state.py | 6 +-
16 files changed, 673 insertions(+), 173 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
