-
- Downloads
[SPARK-14855][SQL] Add "Exec" suffix to physical operators
## What changes were proposed in this pull request? This patch adds "Exec" suffix to all physical operators. Before this patch, Spark's physical operators and logical operators are named the same (e.g. Project could be logical.Project or execution.Project), which caused small issues in code review and bigger issues in code refactoring. ## How was this patch tested? N/A Author: Reynold Xin <rxin@databricks.com> Closes #12617 from rxin/exec-node.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala 6 additions, 3 deletions.../scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala 12 additions, 12 deletions...in/scala/org/apache/spark/sql/execution/ExistingRDD.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/ExpandExec.scala 2 additions, 2 deletions...ain/scala/org/apache/spark/sql/execution/ExpandExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/GenerateExec.scala 2 additions, 2 deletions...n/scala/org/apache/spark/sql/execution/GenerateExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/LocalTableScanExec.scala 2 additions, 2 deletions...a/org/apache/spark/sql/execution/LocalTableScanExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala 3 additions, 3 deletions...scala/org/apache/spark/sql/execution/QueryExecution.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SortExec.scala 2 additions, 2 deletions.../main/scala/org/apache/spark/sql/execution/SortExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala 6 additions, 4 deletions...main/scala/org/apache/spark/sql/execution/SparkPlan.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanInfo.scala 2 additions, 2 deletions.../scala/org/apache/spark/sql/execution/SparkPlanInfo.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala 2 additions, 2 deletions...n/scala/org/apache/spark/sql/execution/SparkPlanner.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 56 additions, 54 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala 11 additions, 11 deletions...rg/apache/spark/sql/execution/WholeStageCodegenExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/WindowExec.scala 2 additions, 2 deletions...ain/scala/org/apache/spark/sql/execution/WindowExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/SortBasedAggregateExec.scala 3 additions, 3 deletions...park/sql/execution/aggregate/SortBasedAggregateExec.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/aggregate/utils.scala 5 additions, 5 deletions...cala/org/apache/spark/sql/execution/aggregate/utils.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/basicOperators.scala 31 additions, 19 deletions...scala/org/apache/spark/sql/execution/basicOperators.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryTableScanExec.scala 3 additions, 3 deletions.../spark/sql/execution/columnar/InMemoryTableScanExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/command/commands.scala 1 addition, 1 deletion...ala/org/apache/spark/sql/execution/command/commands.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala 9 additions, 9 deletions.../spark/sql/execution/datasources/DataSourceStrategy.scala
Loading
Please register or sign in to comment