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 ce818ba96953 [SPARK-45731][SQL] Also update partition statistics with
`ANALYZE TABLE` command
add d9c5f9d6d42a [SPARK-45798][CONNECT] Assert server-side session ID
No new revisions were added by this update.
Summary of changes:
.../spark/sql/connect/client/ArtifactSuite.scala | 6 +-
.../src/main/protobuf/spark/connect/base.proto | 69 +++++-
.../spark/sql/connect/client/ArtifactManager.scala | 10 +-
.../client/CustomSparkConnectBlockingStub.scala | 34 ++-
.../connect/client/CustomSparkConnectStub.scala | 6 +-
.../ExecutePlanResponseReattachableIterator.scala | 19 +-
.../connect/client/GrpcExceptionConverter.scala | 10 +-
.../sql/connect/client/ResponseValidator.scala | 111 +++++++++
.../sql/connect/client/SparkConnectClient.scala | 7 +-
.../sql/connect/client/SparkConnectStubState.scala | 43 ++++
.../artifact/SparkConnectArtifactManager.scala | 2 +-
.../execution/ExecuteResponseObserver.scala | 1 +
.../execution/SparkConnectPlanExecution.scala | 11 +-
.../sql/connect/planner/SparkConnectPlanner.scala | 7 +-
.../spark/sql/connect/service/SessionHolder.scala | 7 +
.../service/SparkConnectAddArtifactsHandler.scala | 2 +
.../service/SparkConnectAnalyzeHandler.scala | 4 +-
.../SparkConnectArtifactStatusesHandler.scala | 5 +
.../service/SparkConnectConfigHandler.scala | 5 +-
.../service/SparkConnectInterruptHandler.scala | 1 +
.../SparkConnectReleaseExecuteHandler.scala | 1 +
.../SparkConnectReleaseSessionHandler.scala | 3 +
.../spark/sql/connect/utils/MetricGenerator.scala | 8 +-
.../spark/sql/connect/SparkConnectServerTest.scala | 7 +-
.../connect/artifact/ArtifactManagerSuite.scala | 18 +-
.../service/ArtifactStatusesHandlerSuite.scala | 7 +-
.../service/SparkConnectServiceE2ESuite.scala | 2 +
python/pyspark/sql/connect/client/core.py | 92 ++++----
python/pyspark/sql/connect/proto/base_pb2.py | 260 ++++++++++-----------
python/pyspark/sql/connect/proto/base_pb2.pyi | 165 +++++++++++--
30 files changed, 671 insertions(+), 252 deletions(-)
create mode 100644
connector/connect/common/src/main/scala/org/apache/spark/sql/connect/client/ResponseValidator.scala
create mode 100644
connector/connect/common/src/main/scala/org/apache/spark/sql/connect/client/SparkConnectStubState.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
