-
- Downloads
[SPARK-9632][SQL] update InternalRow.toSeq to make it accept data type info
This re-applies #7955, which was reverted due to a race condition to fix build breaking. Author: Wenchen Fan <cloud0fan@outlook.com> Author: Reynold Xin <rxin@databricks.com> Closes #8002 from rxin/InternalRow-toSeq and squashes the following commits: 332416a [Reynold Xin] Merge pull request #7955 from cloud-fan/toSeq 21665e2 [Wenchen Fan] fix hive again... 4addf29 [Wenchen Fan] fix hive bc16c59 [Wenchen Fan] minor fix 33d802c [Wenchen Fan] pass data type info to InternalRow.toSeq 3dd033e [Wenchen Fan] move the default special getters implementation from InternalRow to BaseGenericInternalRow
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/InternalRow.scala 9 additions, 123 deletions...ain/scala/org/apache/spark/sql/catalyst/InternalRow.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Projection.scala 8 additions, 4 deletions...rg/apache/spark/sql/catalyst/expressions/Projection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificMutableRow.scala 2 additions, 3 deletions...e/spark/sql/catalyst/expressions/SpecificMutableRow.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateProjection.scala 6 additions, 2 deletions...sql/catalyst/expressions/codegen/GenerateProjection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala 128 additions, 4 deletions...cala/org/apache/spark/sql/catalyst/expressions/rows.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/columnar/ColumnStats.scala 26 additions, 25 deletions...ain/scala/org/apache/spark/sql/columnar/ColumnStats.scala
- sql/core/src/main/scala/org/apache/spark/sql/columnar/InMemoryColumnarTableScan.scala 6 additions, 5 deletions...apache/spark/sql/columnar/InMemoryColumnarTableScan.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala 2 additions, 2 deletions.../scala/org/apache/spark/sql/execution/debug/package.scala
- sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala 2 additions, 2 deletions.../main/scala/org/apache/spark/sql/sources/interfaces.scala
- sql/core/src/test/scala/org/apache/spark/sql/columnar/ColumnStatsSuite.scala 29 additions, 25 deletions...cala/org/apache/spark/sql/columnar/ColumnStatsSuite.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveInspectors.scala 4 additions, 2 deletions...main/scala/org/apache/spark/sql/hive/HiveInspectors.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala 18 additions, 3 deletions...pache/spark/sql/hive/execution/ScriptTransformation.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveWriterContainers.scala 12 additions, 12 deletions...cala/org/apache/spark/sql/hive/hiveWriterContainers.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveInspectorSuite.scala 6 additions, 4 deletions.../scala/org/apache/spark/sql/hive/HiveInspectorSuite.scala
Loading
Please register or sign in to comment