-
- Downloads
[SPARK-9285][SQL] Remove InternalRow's inheritance from Row.
I also changed InternalRow's size/length function to numFields, to make it more obvious that it is not about bytes, but the number of fields. Author: Reynold Xin <rxin@databricks.com> Closes #7626 from rxin/internalRow and squashes the following commits: e124daf [Reynold Xin] Fixed test case. 805ceb7 [Reynold Xin] Commented out the failed test suite. f8a9ca5 [Reynold Xin] Fixed more bugs. Still at least one more remaining. 76d9081 [Reynold Xin] Fixed data sources. 7807f70 [Reynold Xin] Fixed DataFrameSuite. cb60cd2 [Reynold Xin] Code review & small bug fixes. 0a2948b [Reynold Xin] Fixed style. 3280d03 [Reynold Xin] [SPARK-9285][SQL] Remove InternalRow's inheritance from Row.
Showing
- mllib/src/main/scala/org/apache/spark/mllib/linalg/Matrices.scala 2 additions, 2 deletions...c/main/scala/org/apache/spark/mllib/linalg/Matrices.scala
- mllib/src/main/scala/org/apache/spark/mllib/linalg/Vectors.scala 2 additions, 2 deletions...rc/main/scala/org/apache/spark/mllib/linalg/Vectors.scala
- sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java 5 additions, 4 deletions.../org/apache/spark/sql/catalyst/expressions/UnsafeRow.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/CatalystTypeConverters.scala 7 additions, 7 deletions...rg/apache/spark/sql/catalyst/CatalystTypeConverters.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/InternalRow.scala 122 additions, 31 deletions...ain/scala/org/apache/spark/sql/catalyst/InternalRow.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Cast.scala 2 additions, 2 deletions...cala/org/apache/spark/sql/catalyst/expressions/Cast.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Projection.scala 84 additions, 84 deletions...rg/apache/spark/sql/catalyst/expressions/Projection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificMutableRow.scala 2 additions, 2 deletions...e/spark/sql/catalyst/expressions/SpecificMutableRow.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala 2 additions, 2 deletions...rg/apache/spark/sql/catalyst/expressions/aggregates.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateProjection.scala 1 addition, 1 deletion...sql/catalyst/expressions/codegen/GenerateProjection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala 2 additions, 2 deletions...park/sql/catalyst/expressions/complexTypeExtractors.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala 30 additions, 27 deletions...cala/org/apache/spark/sql/catalyst/expressions/rows.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/RowTest.scala 0 additions, 10 deletions...atalyst/src/test/scala/org/apache/spark/sql/RowTest.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/CastSuite.scala 19 additions, 5 deletions...org/apache/spark/sql/catalyst/expressions/CastSuite.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/ComplexTypeSuite.scala 5 additions, 2 deletions...che/spark/sql/catalyst/expressions/ComplexTypeSuite.scala
- sql/core/src/main/scala/org/apache/spark/sql/columnar/ColumnType.scala 1 addition, 1 deletion...main/scala/org/apache/spark/sql/columnar/ColumnType.scala
- sql/core/src/main/scala/org/apache/spark/sql/columnar/InMemoryColumnarTableScan.scala 6 additions, 6 deletions...apache/spark/sql/columnar/InMemoryColumnarTableScan.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer2.scala 5 additions, 5 deletions.../org/apache/spark/sql/execution/SparkSqlSerializer2.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala 2 additions, 2 deletions.../spark/sql/execution/datasources/DataSourceStrategy.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/commands.scala 34 additions, 19 deletions...org/apache/spark/sql/execution/datasources/commands.scala
Loading
Please register or sign in to comment