-
- Downloads
[SPARK-9054] [SQL] Rename RowOrdering to InterpretedOrdering; use newOrdering in SMJ
This patches renames `RowOrdering` to `InterpretedOrdering` and updates SortMergeJoin to use the `SparkPlan` methods for constructing its ordering so that it may benefit from codegen. This is an updated version of #7408. Author: Josh Rosen <joshrosen@databricks.com> Closes #7973 from JoshRosen/SPARK-9054 and squashes the following commits: e610655 [Josh Rosen] Add comment RE: Ascending ordering 34b8e0c [Josh Rosen] Import ordering be19a0f [Josh Rosen] [SPARK-9054] [SQL] Rename RowOrdering to InterpretedOrdering; use newOrdering in more places.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala 2 additions, 2 deletions...rg/apache/spark/sql/catalyst/expressions/arithmetic.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/conditionals.scala 2 additions, 2 deletions.../apache/spark/sql/catalyst/expressions/conditionals.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ordering.scala 15 additions, 12 deletions.../org/apache/spark/sql/catalyst/expressions/ordering.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala 4 additions, 4 deletions...rg/apache/spark/sql/catalyst/expressions/predicates.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/TypeUtils.scala 2 additions, 2 deletions.../scala/org/apache/spark/sql/catalyst/util/TypeUtils.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/types/StructType.scala 2 additions, 2 deletions...rc/main/scala/org/apache/spark/sql/types/StructType.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/CodeGenerationSuite.scala 1 addition, 1 deletion.../spark/sql/catalyst/expressions/CodeGenerationSuite.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala 4 additions, 1 deletion.../main/scala/org/apache/spark/sql/execution/Exchange.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala 12 additions, 2 deletions...main/scala/org/apache/spark/sql/execution/SparkPlan.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/basicOperators.scala 3 additions, 1 deletion...scala/org/apache/spark/sql/execution/basicOperators.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala 5 additions, 4 deletions.../org/apache/spark/sql/execution/joins/SortMergeJoin.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/UnsafeKVExternalSorterSuite.scala 3 additions, 3 deletions...che/spark/sql/execution/UnsafeKVExternalSorterSuite.scala
Loading
Please register or sign in to comment