-
- Downloads
[SPARK-13237] [SQL] generated broadcast outer join
This PR support codegen for broadcast outer join. In order to reduce the duplicated codes, this PR merge HashJoin and HashOuterJoin together (also BroadcastHashJoin and BroadcastHashOuterJoin). Author: Davies Liu <davies@databricks.com> Closes #11130 from davies/gen_out.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 8 additions, 8 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegen.scala 4 additions, 4 deletions...la/org/apache/spark/sql/execution/WholeStageCodegen.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala 199 additions, 54 deletions.../apache/spark/sql/execution/joins/BroadcastHashJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashOuterJoin.scala 0 additions, 121 deletions...he/spark/sql/execution/joins/BroadcastHashOuterJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala 103 additions, 8 deletions...scala/org/apache/spark/sql/execution/joins/HashJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashOuterJoin.scala 0 additions, 153 deletions.../org/apache/spark/sql/execution/joins/HashOuterJoin.scala
- sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala 2 additions, 3 deletionssql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/BenchmarkWholeStageCodegen.scala 119 additions, 12 deletions...ache/spark/sql/execution/BenchmarkWholeStageCodegen.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/joins/BroadcastJoinSuite.scala 1 addition, 1 deletion...apache/spark/sql/execution/joins/BroadcastJoinSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala 1 addition, 1 deletion...org/apache/spark/sql/execution/joins/InnerJoinSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/joins/OuterJoinSuite.scala 7 additions, 2 deletions...org/apache/spark/sql/execution/joins/OuterJoinSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/metric/SQLMetricsSuite.scala 4 additions, 4 deletions...g/apache/spark/sql/execution/metric/SQLMetricsSuite.scala
Loading
Please register or sign in to comment