Github user maropu commented on a diff in the pull request: https://github.com/apache/spark/pull/21657#discussion_r200210431 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/UnivocityParser.scala --- @@ -82,7 +83,12 @@ class UnivocityParser( // // output row - ["A", 2] private val valueConverters: Array[ValueConverter] = { - schema.map(f => makeConverter(f.name, f.dataType, f.nullable, options)).toArray + requiredSchema.map(f => makeConverter(f.name, f.dataType, f.nullable, options)).toArray + } + + // If `columnPruning` disabled, this index is used to reorder parsed tokens + private lazy val tokenIndexArr: Array[Int] = { + requiredSchema.map(f => dataSchema.indexOf(f)).toArray --- End diff -- ok
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org