Commit 6c5bbd62 authored 9 years ago by Reynold Xin

Revert "Revert "[SPARK-12286][SPARK-12290][SPARK-12294][SPARK-12284][SQL] always output UnsafeRow""

This reverts commit 44ee920f.

parent 513e3b09

No related branches found

No related tags found

No related merge requests found

Hide whitespace changes

Inline Side-by-side

Showing

sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 1 addition, 2 deletions

...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala 2 additions, 23 deletions

.../main/scala/org/apache/spark/sql/execution/Exchange.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala 12 additions, 3 deletions

...in/scala/org/apache/spark/sql/execution/ExistingRDD.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/Expand.scala 2 additions, 11 deletions

...rc/main/scala/org/apache/spark/sql/execution/Expand.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/Generate.scala 5 additions, 3 deletions

.../main/scala/org/apache/spark/sql/execution/Generate.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/LocalTableScan.scala 9 additions, 4 deletions

...scala/org/apache/spark/sql/execution/LocalTableScan.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/Sort.scala 0 additions, 4 deletions

.../src/main/scala/org/apache/spark/sql/execution/Sort.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala 0 additions, 23 deletions

...main/scala/org/apache/spark/sql/execution/SparkPlan.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala 3 additions, 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 0 additions, 4 deletions

...he/spark/sql/execution/aggregate/SortBasedAggregate.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/SortBasedAggregationIterator.scala 6 additions, 2 deletions

...ql/execution/aggregate/SortBasedAggregationIterator.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregate.scala 0 additions, 4 deletions

...che/spark/sql/execution/aggregate/TungstenAggregate.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/basicOperators.scala 6 additions, 52 deletions

...scala/org/apache/spark/sql/execution/basicOperators.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryColumnarTableScan.scala 2 additions, 6 deletions

...rk/sql/execution/columnar/InMemoryColumnarTableScan.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastNestedLoopJoin.scala 0 additions, 7 deletions

...e/spark/sql/execution/joins/BroadcastNestedLoopJoin.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/CartesianProduct.scala 0 additions, 4 deletions

...g/apache/spark/sql/execution/joins/CartesianProduct.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala 0 additions, 4 deletions

...scala/org/apache/spark/sql/execution/joins/HashJoin.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashOuterJoin.scala 0 additions, 4 deletions

.../org/apache/spark/sql/execution/joins/HashOuterJoin.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashSemiJoin.scala 0 additions, 4 deletions

...a/org/apache/spark/sql/execution/joins/HashSemiJoin.scala
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/LeftSemiJoinBNL.scala 0 additions, 3 deletions

...rg/apache/spark/sql/execution/joins/LeftSemiJoinBNL.scala

with 48 additions and 172 deletions

Please register or to comment