-
- Downloads
[SPARK-14175][SQL] whole stage codegen interface refactor
## What changes were proposed in this pull request? 1. merge consumeChild into consume() 2. always generate code for input variables and UnsafeRow, a plan can use eight of them. ## How was this patch tested? Existing tests. Author: Davies Liu <davies@databricks.com> Closes #11975 from davies/gen_refactor.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala 2 additions, 1 deletion...in/scala/org/apache/spark/sql/execution/ExistingRDD.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/Expand.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/sql/execution/Expand.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/Sort.scala 7 additions, 19 deletions.../src/main/scala/org/apache/spark/sql/execution/Sort.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegen.scala 56 additions, 97 deletions...la/org/apache/spark/sql/execution/WholeStageCodegen.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregate.scala 1 addition, 1 deletion...che/spark/sql/execution/aggregate/TungstenAggregate.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/basicOperators.scala 2 additions, 2 deletions...scala/org/apache/spark/sql/execution/basicOperators.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala 1 addition, 1 deletion.../scala/org/apache/spark/sql/execution/debug/package.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala 1 addition, 1 deletion.../apache/spark/sql/execution/joins/BroadcastHashJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala 1 addition, 1 deletion...src/main/scala/org/apache/spark/sql/execution/limit.scala
Loading
Please register or sign in to comment