We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e5e60ad commit 6b19f57Copy full SHA for 6b19f57
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRowConverter.scala
@@ -183,7 +183,7 @@ private[parquet] class ParquetRowConverter(
183
// Converters for each field.
184
private val fieldConverters: Array[Converter with HasParentContainerUpdater] = {
185
parquetType.getFields.asScala.map {
186
- case parquetField =>
+ parquetField =>
187
val fieldIndex = catalystType.fieldIndex(parquetField.getName)
188
val catalystField = catalystType(fieldIndex)
189
// Converted field value should be set to the `fieldIndex`-th cell of `currentRow`
0 commit comments