You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2021/04/28 17:41:36 UTC
[spark] branch master updated (0bcf348 -> 86d3bb5)
This is an automated email from the ASF dual-hosted git repository.
wenchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from 0bcf348 [SPARK-34781][SQL][FOLLOWUP] Adjust the order of AQE optimizer rules
add 86d3bb5 [SPARK-34981][SQL] Implement V2 function resolution and evaluation
No new revisions were added by this update.
Summary of changes:
.../catalog/functions/AggregateFunction.java | 15 +-
.../catalog/functions/ScalarFunction.java | 58 ++-
.../spark/sql/catalyst/analysis/Analyzer.scala | 168 +++++++--
.../catalyst/analysis/higherOrderFunctions.scala | 9 +-
.../spark/sql/catalyst/analysis/unresolved.scala | 18 +-
.../sql/catalyst/catalog/SessionCatalog.scala | 5 +-
.../expressions/ApplyFunctionExpression.scala | 46 +++
.../expressions/aggregate/V2Aggregator.scala | 70 ++++
.../spark/sql/catalyst/parser/AstBuilder.scala | 19 +-
.../sql/connector/catalog/CatalogV2Implicits.scala | 32 ++
.../sql/connector/catalog/LookupCatalog.scala | 22 ++
.../spark/sql/errors/QueryCompilationErrors.scala | 6 -
.../catalyst/analysis/LookupFunctionsSuite.scala | 7 +-
.../connector/catalog/CatalogManagerSuite.scala | 4 +-
...{TableCatalogSuite.scala => CatalogSuite.scala} | 50 ++-
.../sql/connector/catalog/InMemoryCatalog.scala | 58 +++
.../connector/catalog/InMemoryTableCatalog.scala | 2 +-
.../connector/catalog/functions/JavaAverage.java | 102 +++++
.../connector/catalog/functions/JavaStrLen.java | 122 ++++++
.../sql/connector/DataSourceV2FunctionSuite.scala | 420 +++++++++++++++++++++
.../spark/sql/connector/DatasourceV2SQLBase.scala | 6 +-
21 files changed, 1163 insertions(+), 76 deletions(-)
create mode 100644 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ApplyFunctionExpression.scala
create mode 100644 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/V2Aggregator.scala
rename sql/catalyst/src/test/scala/org/apache/spark/sql/connector/catalog/{TableCatalogSuite.scala => CatalogSuite.scala} (93%)
create mode 100644 sql/catalyst/src/test/scala/org/apache/spark/sql/connector/catalog/InMemoryCatalog.scala
create mode 100644 sql/core/src/test/java/test/org/apache/spark/sql/connector/catalog/functions/JavaAverage.java
create mode 100644 sql/core/src/test/java/test/org/apache/spark/sql/connector/catalog/functions/JavaStrLen.java
create mode 100644 sql/core/src/test/scala/org/apache/spark/sql/connector/DataSourceV2FunctionSuite.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org