-
- Downloads
[SPARK-9990] [SQL] Create local hash join operator
This PR includes the following changes: - Add SQLConf to LocalNode - Add HashJoinNode - Add ConvertToUnsafeNode and ConvertToSafeNode.scala to test unsafe hash join. Author: zsxwing <zsxwing@gmail.com> Closes #8535 from zsxwing/SPARK-9990.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala 2 additions, 2 deletions...org/apache/spark/sql/execution/joins/HashedRelation.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/ConvertToSafeNode.scala 40 additions, 0 deletions.../apache/spark/sql/execution/local/ConvertToSafeNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/ConvertToUnsafeNode.scala 40 additions, 0 deletions...pache/spark/sql/execution/local/ConvertToUnsafeNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/FilterNode.scala 3 additions, 1 deletion...ala/org/apache/spark/sql/execution/local/FilterNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/HashJoinNode.scala 137 additions, 0 deletions...a/org/apache/spark/sql/execution/local/HashJoinNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/LimitNode.scala 2 additions, 1 deletion...cala/org/apache/spark/sql/execution/local/LimitNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/LocalNode.scala 78 additions, 5 deletions...cala/org/apache/spark/sql/execution/local/LocalNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/ProjectNode.scala 3 additions, 1 deletion...la/org/apache/spark/sql/execution/local/ProjectNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/SeqScanNode.scala 3 additions, 1 deletion...la/org/apache/spark/sql/execution/local/SeqScanNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/UnionNode.scala 2 additions, 1 deletion...cala/org/apache/spark/sql/execution/local/UnionNode.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/local/FilterNodeSuite.scala 2 additions, 2 deletions...rg/apache/spark/sql/execution/local/FilterNodeSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/local/HashJoinNodeSuite.scala 130 additions, 0 deletions.../apache/spark/sql/execution/local/HashJoinNodeSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/local/LimitNodeSuite.scala 2 additions, 2 deletions...org/apache/spark/sql/execution/local/LimitNodeSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/local/LocalNodeTest.scala 6 additions, 3 deletions.../org/apache/spark/sql/execution/local/LocalNodeTest.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/local/ProjectNodeSuite.scala 2 additions, 2 deletions...g/apache/spark/sql/execution/local/ProjectNodeSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/local/UnionNodeSuite.scala 3 additions, 3 deletions...org/apache/spark/sql/execution/local/UnionNodeSuite.scala
Loading
Please register or sign in to comment