File tree Expand file tree Collapse file tree 1 file changed +12
-8
lines changed
sql/core/src/main/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +12
-8
lines changed Original file line number Diff line number Diff line change @@ -419,7 +419,9 @@ private[parquet] class CatalystMapConverter(
419419 val keyConverter = CatalystConverter .createConverter(schema(0 ), 0 , this )
420420 val valueConverter = CatalystConverter .createConverter(schema(1 ), 1 , this )
421421
422- override def getConverter (fieldIndex : Int ): Converter = if (fieldIndex == 0 ) keyConverter else valueConverter
422+ override def getConverter (fieldIndex : Int ): Converter = {
423+ if (fieldIndex == 0 ) keyConverter else valueConverter
424+ }
423425
424426 override def end (): Unit = CatalystMapConverter .this .map += currentKey -> currentValue
425427
@@ -432,13 +434,15 @@ private[parquet] class CatalystMapConverter(
432434 override protected [parquet] val index : Int = 0
433435 override protected [parquet] val parent : CatalystConverter = CatalystMapConverter .this
434436
435- override protected [parquet] def updateField (fieldIndex : Int , value : Any ): Unit = fieldIndex match {
436- case 0 =>
437- currentKey = value
438- case 1 =>
439- currentValue = value
440- case _ =>
441- new RuntimePermission (s " trying to update Map with fieldIndex $fieldIndex" )
437+ override protected [parquet] def updateField (fieldIndex : Int , value : Any ): Unit = {
438+ fieldIndex match {
439+ case 0 =>
440+ currentKey = value
441+ case 1 =>
442+ currentValue = value
443+ case _ =>
444+ new RuntimePermission (s " trying to update Map with fieldIndex $fieldIndex" )
445+ }
442446 }
443447
444448 override protected [parquet] def clearBuffer (): Unit = {}
You can’t perform that action at this time.
0 commit comments