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(
419
419
val keyConverter = CatalystConverter .createConverter(schema(0 ), 0 , this )
420
420
val valueConverter = CatalystConverter .createConverter(schema(1 ), 1 , this )
421
421
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
+ }
423
425
424
426
override def end (): Unit = CatalystMapConverter .this .map += currentKey -> currentValue
425
427
@@ -432,13 +434,15 @@ private[parquet] class CatalystMapConverter(
432
434
override protected [parquet] val index : Int = 0
433
435
override protected [parquet] val parent : CatalystConverter = CatalystMapConverter .this
434
436
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
+ }
442
446
}
443
447
444
448
override protected [parquet] def clearBuffer (): Unit = {}
You can’t perform that action at this time.
0 commit comments