This is an automated email from the ASF dual-hosted git repository.
ptoth pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 89fd0827015d [SPARK-55854][SQL] Tag pass-through duplicate attributes
in Expand output to prevent AMBIGUOUS_REFERENCE
add a1c62ddde85c [SPARK-55535][SPARK-55092][SQL] Refactor
`KeyGroupedPartitioning` and Storage Partition Join
No new revisions were added by this update.
Summary of changes:
.../main/scala/org/apache/spark/Partitioner.scala | 2 +-
.../sql/catalyst/plans/physical/partitioning.scala | 336 ++++++++-----
.../util/InternalRowComparableWrapper.scala | 27 -
.../InternalRowComparableWrapperBenchmark.scala | 28 +-
.../sql/execution/KeyGroupedPartitionedScan.scala | 184 -------
.../execution/datasources/v2/BatchScanExec.scala | 88 ++--
.../datasources/v2/ContinuousScanExec.scala | 4 +-
.../execution/datasources/v2/DataSourceRDD.scala | 92 ++--
.../datasources/v2/DataSourceV2ScanExecBase.scala | 99 +---
.../datasources/v2/DataSourceV2Strategy.scala | 4 +-
.../datasources/v2/GroupPartitionsExec.scala | 230 +++++++++
.../execution/exchange/EnsureRequirements.scala | 471 +++++++++---------
.../execution/exchange/ShuffleExchangeExec.scala | 11 +-
.../joins/StoragePartitionJoinParams.scala | 48 --
.../DistributionAndOrderingSuiteBase.scala | 5 +-
.../connector/KeyGroupedPartitioningSuite.scala | 551 +++++++++++++++------
.../exchange/EnsureRequirementsSuite.scala | 199 ++++----
17 files changed, 1322 insertions(+), 1057 deletions(-)
delete mode 100644
sql/core/src/main/scala/org/apache/spark/sql/execution/KeyGroupedPartitionedScan.scala
create mode 100644
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/GroupPartitionsExec.scala
delete mode 100644
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/StoragePartitionJoinParams.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
