-
- Downloads
[SPARK-12585] [SQL] move numFields to constructor of UnsafeRow
Right now, numFields will be passed in by pointTo(), then bitSetWidthInBytes is calculated, making pointTo() a little bit heavy. It should be part of constructor of UnsafeRow. Author: Davies Liu <davies@databricks.com> Closes #10528 from davies/numFields.
Showing
- sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeArrayData.java 2 additions, 2 deletions...pache/spark/sql/catalyst/expressions/UnsafeArrayData.java
- sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java 25 additions, 63 deletions.../org/apache/spark/sql/catalyst/expressions/UnsafeRow.java
- sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java 8 additions, 8 deletions...g/apache/spark/sql/execution/UnsafeExternalRowSorter.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala 2 additions, 2 deletions...talyst/expressions/codegen/GenerateUnsafeProjection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeRowJoiner.scala 2 additions, 2 deletions...atalyst/expressions/codegen/GenerateUnsafeRowJoiner.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeRowJoinerBitsetSuite.scala 2 additions, 2 deletions...ressions/codegen/GenerateUnsafeRowJoinerBitsetSuite.scala
- sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeFixedWidthAggregationMap.java 4 additions, 6 deletions...e/spark/sql/execution/UnsafeFixedWidthAggregationMap.java
- sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java 12 additions, 12 deletions...rg/apache/spark/sql/execution/UnsafeKVExternalSorter.java
- sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/UnsafeRowParquetRecordReader.java 12 additions, 20 deletions...ion/datasources/parquet/UnsafeRowParquetRecordReader.java
- sql/core/src/main/scala/org/apache/spark/sql/execution/UnsafeRowSerializer.scala 3 additions, 3 deletions.../org/apache/spark/sql/execution/UnsafeRowSerializer.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnType.scala 1 addition, 2 deletions.../org/apache/spark/sql/execution/columnar/ColumnType.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala 2 additions, 2 deletions...spark/sql/execution/columnar/GenerateColumnAccessor.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala 2 additions, 2 deletions.../spark/sql/execution/datasources/text/DefaultSource.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/CartesianProduct.scala 2 additions, 3 deletions...g/apache/spark/sql/execution/joins/CartesianProduct.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala 2 additions, 2 deletions...org/apache/spark/sql/execution/joins/HashedRelation.scala
- sql/core/src/test/scala/org/apache/spark/sql/UnsafeRowSuite.scala 5 additions, 6 deletions.../src/test/scala/org/apache/spark/sql/UnsafeRowSuite.scala
Loading
Please register or sign in to comment