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 2020/05/27 15:51:52 UTC
[spark] branch master updated (50492c0 -> f6f1e51)
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 50492c0 [SPARK-31803][ML] Make sure instance weight is not negative
add f6f1e51 [SPARK-31719][SQL] Refactor JoinSelection
No new revisions were added by this update.
Summary of changes:
.../spark/sql/catalyst/optimizer/joins.scala | 158 +++++++++++++++++
.../optimizer/JoinSelectionHelperSuite.scala | 186 +++++++++++++++++++++
.../spark/sql/execution/SparkStrategies.scala | 153 ++++-------------
.../adaptive/LogicalQueryStageStrategy.scala | 3 +-
.../adaptive/OptimizeLocalShuffleReader.scala | 3 +-
.../dynamicpruning/PlanDynamicPruningFilters.scala | 1 +
.../execution/joins/BroadcastHashJoinExec.scala | 1 +
.../joins/BroadcastNestedLoopJoinExec.scala | 1 +
.../spark/sql/execution/joins/HashJoin.scala | 1 +
.../sql/execution/joins/ShuffledHashJoinExec.scala | 1 +
.../apache/spark/sql/execution/joins/package.scala | 31 ----
.../scala/org/apache/spark/sql/JoinHintSuite.scala | 2 +-
.../adaptive/AdaptiveQueryExecSuite.scala | 3 +-
.../sql/execution/joins/BroadcastJoinSuite.scala | 1 +
.../sql/execution/joins/ExistenceJoinSuite.scala | 1 +
.../spark/sql/execution/joins/InnerJoinSuite.scala | 9 +-
.../spark/sql/execution/joins/OuterJoinSuite.scala | 1 +
17 files changed, 395 insertions(+), 161 deletions(-)
create mode 100644 sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/JoinSelectionHelperSuite.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/package.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org