-
- Downloads
[SPARK-11673][SQL] Remove the normal Project physical operator (and keep TungstenProject)
Also make full outer join being able to produce UnsafeRows. Author: Reynold Xin <rxin@databricks.com> Closes #9643 from rxin/SPARK-11673.
Showing
- sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java 0 additions, 7 deletions...g/apache/spark/sql/execution/UnsafeExternalRowSorter.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala 4 additions, 4 deletions...atalyst/src/main/scala/org/apache/spark/sql/Encoder.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala 3 additions, 3 deletions...scala/org/apache/spark/sql/catalyst/ScalaReflection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/EquivalentExpressions.scala 1 addition, 1 deletion...park/sql/catalyst/expressions/EquivalentExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Projection.scala 0 additions, 10 deletions...rg/apache/spark/sql/catalyst/expressions/Projection.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala 1 addition, 4 deletions.../main/scala/org/apache/spark/sql/execution/Exchange.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala 2 additions, 4 deletions...n/scala/org/apache/spark/sql/execution/SparkPlanner.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 2 additions, 12 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala 1 addition, 5 deletions...rc/main/scala/org/apache/spark/sql/execution/Window.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/SortBasedAggregate.scala 2 additions, 4 deletions...he/spark/sql/execution/aggregate/SortBasedAggregate.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregate.scala 1 addition, 2 deletions...che/spark/sql/execution/aggregate/TungstenAggregate.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/basicOperators.scala 0 additions, 26 deletions...scala/org/apache/spark/sql/execution/basicOperators.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala 2 additions, 1 deletion.../spark/sql/execution/datasources/DataSourceStrategy.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala 7 additions, 24 deletions...scala/org/apache/spark/sql/execution/joins/HashJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashOuterJoin.scala 19 additions, 35 deletions.../org/apache/spark/sql/execution/joins/HashOuterJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashSemiJoin.scala 5 additions, 20 deletions...a/org/apache/spark/sql/execution/joins/HashSemiJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala 7 additions, 34 deletions.../org/apache/spark/sql/execution/joins/SortMergeJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeOuterJoin.scala 8 additions, 30 deletions...apache/spark/sql/execution/joins/SortMergeOuterJoin.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/BinaryHashJoinNode.scala 1 addition, 5 deletions...apache/spark/sql/execution/local/BinaryHashJoinNode.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/local/HashJoinNode.scala 3 additions, 18 deletions...a/org/apache/spark/sql/execution/local/HashJoinNode.scala
Loading
Please register or sign in to comment