File tree Expand file tree Collapse file tree 1 file changed +8
-5
lines changed
sql/core/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +8
-5
lines changed Original file line number Diff line number Diff line change @@ -1106,11 +1106,14 @@ object SQLContext {
11061106 method -> createConverter(method.getReturnType, fieldType)
11071107 }
11081108 value =>
1109- if (value == null ) null
1110- else new GenericInternalRow (
1111- methodConverters.map { case (method, converter) =>
1112- converter(method.invoke(value))
1113- })
1109+ if (value == null ) {
1110+ null
1111+ } else {
1112+ new GenericInternalRow (
1113+ methodConverters.map { case (method, converter) =>
1114+ converter(method.invoke(value))
1115+ })
1116+ }
11141117 }
11151118 def createConverter (cls : Class [_], dataType : DataType ): Any => Any = dataType match {
11161119 case struct : StructType => createStructConverter(cls, struct.map(_.dataType))
You can’t perform that action at this time.
0 commit comments