-
- Downloads
[SPARK-10484] [SQL] Optimize the cartesian join with broadcast join for some cases
In some cases, we can broadcast the smaller relation in cartesian join, which improve the performance significantly. Author: Cheng Hao <hao.cheng@intel.com> Closes #8652 from chenghao-intel/cartesian.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala 2 additions, 1 deletion...n/scala/org/apache/spark/sql/execution/SparkPlanner.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 26 additions, 12 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastNestedLoopJoin.scala 5 additions, 2 deletions...e/spark/sql/execution/joins/BroadcastNestedLoopJoin.scala
- sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala 92 additions, 0 deletionssql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala 2 additions, 1 deletion...rc/main/scala/org/apache/spark/sql/hive/HiveContext.scala
- sql/hive/src/test/resources/golden/SPARK-10484 Optimize the Cartesian (Cross) Join with broadcast based JOIN #1-0-abfc0b99ee357f71639f6162345fe8e 20 additions, 0 deletions...broadcast based JOIN #1-0-abfc0b99ee357f71639f6162345fe8e
- sql/hive/src/test/resources/golden/SPARK-10484 Optimize the Cartesian (Cross) Join with broadcast based JOIN #2-0-8412a39ee57885ccb0aaf848db8ef1dd 20 additions, 0 deletions...roadcast based JOIN #2-0-8412a39ee57885ccb0aaf848db8ef1dd
- sql/hive/src/test/resources/golden/SPARK-10484 Optimize the Cartesian (Cross) Join with broadcast based JOIN #3-0-e8a0427dbde35eea6011144443e5ffb4 20 additions, 0 deletions...roadcast based JOIN #3-0-e8a0427dbde35eea6011144443e5ffb4
- sql/hive/src/test/resources/golden/SPARK-10484 Optimize the Cartesian (Cross) Join with broadcast based JOIN #4-0-45f8602d257655322b7d18cad09f6a0f 20 additions, 0 deletions...roadcast based JOIN #4-0-45f8602d257655322b7d18cad09f6a0f
- sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala 54 additions, 0 deletions.../org/apache/spark/sql/hive/execution/HiveQuerySuite.scala
Loading
Please register or sign in to comment