You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ge...@apache.org on 2025/05/20 20:16:45 UTC
(spark) branch master updated (4b3a65307681 -> 315be9f475a3)
This is an automated email from the ASF dual-hosted git repository.
gengliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 4b3a65307681 [SPARK-51820][SQL][FOLLOWUP][CONNECT] Don't add `UnresolvedOrdinal` when appending grouping to aggregate expressions
add 315be9f475a3 [SPARK-52110][SDP][SQL] Implement SQL syntax support for pipelines
No new revisions were added by this update.
Summary of changes:
.../src/main/resources/error/error-conditions.json | 16 ++
docs/sql-ref-ansi-compliance.md | 4 +
.../spark/sql/catalyst/parser/SqlBaseLexer.g4 | 4 +
.../spark/sql/catalyst/parser/SqlBaseParser.g4 | 39 ++-
.../analysis/UnsupportedOperationChecker.scala | 3 +-
.../spark/sql/catalyst/parser/AstBuilder.scala | 35 ++-
.../sql/catalyst/plans/logical/v2Commands.scala | 126 ++++++++++
.../spark/sql/errors/QueryCompilationErrors.scala | 20 ++
.../parser/StreamRelationParserSuite.scala | 93 +++++++
.../apache/spark/sql/execution/SparkPlanner.scala | 1 +
.../spark/sql/execution/SparkSqlParser.scala | 128 ++++++++++
.../spark/sql/execution/SparkStrategies.scala | 14 ++
.../sql-tests/results/keywords-enforced.sql.out | 4 +
.../resources/sql-tests/results/keywords.sql.out | 4 +
.../sql-tests/results/nonansi/keywords.sql.out | 4 +
.../spark/sql/execution/QueryExecutionSuite.scala | 3 +-
...atePipelineDatasetAsSelectParserSuiteBase.scala | 274 +++++++++++++++++++++
.../spark/sql/execution/command/DDLSuite.scala | 53 +++-
.../command/v2/CreateFlowCommandSuite.scala | 73 ++++++
...reateMaterializedViewAsSelectParserSuite.scala} | 21 +-
.../CreateStreamingTableAsSelectParserSuite.scala | 11 +-
.../v2/CreateStreamingTableParserSuite.scala | 57 +++++
.../execution/streaming/StreamRelationSuite.scala | 157 ++++++++++++
.../streaming/sources/ForeachBatchSinkSuite.scala | 3 +-
.../ThriftServerWithSparkContextSuite.scala | 2 +-
25 files changed, 1117 insertions(+), 32 deletions(-)
create mode 100644 sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/parser/StreamRelationParserSuite.scala
create mode 100644 sql/core/src/test/scala/org/apache/spark/sql/execution/command/CreatePipelineDatasetAsSelectParserSuiteBase.scala
create mode 100644 sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/CreateFlowCommandSuite.scala
copy sql/core/src/{main/scala/org/apache/spark/sql/execution/command/CommandCheck.scala => test/scala/org/apache/spark/sql/execution/command/v2/CreateMaterializedViewAsSelectParserSuite.scala} (60%)
copy common/network-common/src/main/java/org/apache/spark/network/util/IOMode.java => sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/CreateStreamingTableAsSelectParserSuite.scala (73%)
create mode 100644 sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/CreateStreamingTableParserSuite.scala
create mode 100644 sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/StreamRelationSuite.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org