@@ -75,8 +75,7 @@ public T fromRow(@Nullable InternalRow row) {
7575 for (int i = 0 ; i < rowReaders .length ; i ++) {
7676 if (!row .isNullAt (i )) {
7777 Object v = rowReaders [i ].convert (row , i );
78- PojoType .Property prop =
79- pojoType .getProperty (projectionFieldNames .get (i ));
78+ PojoType .Property prop = pojoType .getProperty (projectionFieldNames .get (i ));
8079 if (v != null ) {
8180 prop .write (pojo , v );
8281 }
@@ -150,14 +149,16 @@ private static RowToField createRowReader(DataType fieldType, PojoType.Property
150149 return RowToPojoConverter ::convertDateValue ;
151150 case TIME_WITHOUT_TIME_ZONE :
152151 return RowToPojoConverter ::convertTimeValue ;
153- case TIMESTAMP_WITHOUT_TIME_ZONE : {
154- final int precision = DataTypeChecks .getPrecision (fieldType );
155- return (row , pos ) -> convertTimestampNtzValue (precision , row , pos );
156- }
157- case TIMESTAMP_WITH_LOCAL_TIME_ZONE : {
158- final int precision = DataTypeChecks .getPrecision (fieldType );
159- return (row , pos ) -> convertTimestampLtzValue (precision , prop , row , pos );
160- }
152+ case TIMESTAMP_WITHOUT_TIME_ZONE :
153+ {
154+ final int precision = DataTypeChecks .getPrecision (fieldType );
155+ return (row , pos ) -> convertTimestampNtzValue (precision , row , pos );
156+ }
157+ case TIMESTAMP_WITH_LOCAL_TIME_ZONE :
158+ {
159+ final int precision = DataTypeChecks .getPrecision (fieldType );
160+ return (row , pos ) -> convertTimestampLtzValue (precision , prop , row , pos );
161+ }
161162 default :
162163 throw new UnsupportedOperationException (
163164 String .format (
0 commit comments