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 2023/09/20 15:07:54 UTC
[spark] branch master updated (d92d6f60342c -> 288a92b9f41e)
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 d92d6f60342c [SPARK-43979][SQL][FOLLOWUP] Handle non alias-only project case
add 288a92b9f41e [SPARK-45112][SQL] Use UnresolvedFunction based resolution in SQL Dataset functions
No new revisions were added by this update.
Summary of changes:
R/pkg/R/functions.R | 2 +
.../scala/org/apache/spark/sql/functions.scala | 3 +-
.../org/apache/spark/sql/FunctionTestSuite.scala | 1 -
.../explain-results/function_arrays_zip.explain | 2 +-
.../explain-results/function_concat.explain | 2 +-
.../explain-results/function_flatten.explain | 2 +-
.../explain-results/function_sequence.explain | 2 +-
.../query-tests/queries/function_arrays_zip.json | 4 -
.../queries/function_arrays_zip.proto.bin | Bin 211 -> 205 bytes
.../query-tests/queries/function_concat.json | 4 -
.../query-tests/queries/function_concat.proto.bin | Bin 230 -> 224 bytes
.../query-tests/queries/function_flatten.json | 4 -
.../query-tests/queries/function_flatten.proto.bin | Bin 219 -> 213 bytes
.../query-tests/queries/function_sequence.json | 4 -
.../queries/function_sequence.proto.bin | Bin 188 -> 182 bytes
python/pyspark/sql/column.py | 10 +-
python/pyspark/sql/connect/column.py | 2 +-
python/pyspark/sql/connect/functions.py | 4 +-
python/pyspark/sql/functions.py | 22 +-
.../catalyst/expressions/complexTypeCreator.scala | 1 +
.../spark/sql/errors/QueryExecutionErrors.scala | 4 +-
.../main/scala/org/apache/spark/sql/Column.scala | 148 +-
.../spark/sql/RelationalGroupedDataset.scala | 8 +-
.../org/apache/spark/sql/api/r/SQLUtils.scala | 6 +-
.../scala/org/apache/spark/sql/functions.scala | 1763 ++++++++------------
.../apache/spark/sql/ColumnExpressionSuite.scala | 2 +-
.../apache/spark/sql/DataFrameAggregateSuite.scala | 57 +-
.../apache/spark/sql/DataFrameFunctionsSuite.scala | 20 +-
.../org/apache/spark/sql/DataFrameSuite.scala | 14 +-
.../apache/spark/sql/IntegratedUDFTestUtils.scala | 41 +-
.../sql/errors/QueryCompilationErrorsSuite.scala | 4 +-
.../sql/errors/QueryExecutionErrorsSuite.scala | 2 +-
.../sql/execution/joins/ExistenceJoinSuite.scala | 10 +-
.../spark/sql/execution/joins/InnerJoinSuite.scala | 12 +-
.../spark/sql/execution/joins/OuterJoinSuite.scala | 6 +-
.../sql/execution/python/PythonUDFSuite.scala | 5 +-
.../StreamingSymmetricHashJoinHelperSuite.scala | 74 +-
37 files changed, 965 insertions(+), 1280 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org