Minor tweaks for readability

deephaven · Nov 9, 2023 · a48ea8d · a48ea8d
1 parent 9b73db5
commit a48ea8d
Showing 1 changed file with 10 additions and 7 deletions.
diff --git a/extensions/parquet/table/src/main/java/io/deephaven/parquet/table/ParquetSchemaReader.java b/extensions/parquet/table/src/main/java/io/deephaven/parquet/table/ParquetSchemaReader.java
@@ -351,14 +351,17 @@ public Optional<Class<?>> visit(final LogicalTypeAnnotation.TimeLogicalTypeAnnot
             @Override
             public Optional<Class<?>> visit(
                     final LogicalTypeAnnotation.TimestampLogicalTypeAnnotation timestampLogicalType) {
-                final LogicalTypeAnnotation.TimeUnit unit = timestampLogicalType.getUnit();
-                final boolean isAdjustedToUTC = timestampLogicalType.isAdjustedToUTC();
-                if (unit != LogicalTypeAnnotation.TimeUnit.MILLIS && unit != LogicalTypeAnnotation.TimeUnit.MICROS
-                        && unit != LogicalTypeAnnotation.TimeUnit.NANOS) {
-                    errorString.setValue("TimestampLogicalType, isAdjustedToUTC=" + isAdjustedToUTC + ", unit=" + unit);
-                    return Optional.empty();
+                switch (timestampLogicalType.getUnit()) {
+                    case MILLIS:
+                    case MICROS:
+                    case NANOS:
+                        // TIMESTAMP fields if adjusted to UTC are read as Instants, else as LocalDatetimes.
+                        return timestampLogicalType.isAdjustedToUTC() ? Optional.of(Instant.class)
+                                : Optional.of(LocalDateTime.class);
                 }
-                return isAdjustedToUTC ? Optional.of(Instant.class) : Optional.of(LocalDateTime.class);
+                errorString.setValue("TimestampLogicalType, isAdjustedToUTC=" + timestampLogicalType.isAdjustedToUTC()
+                        + ", unit=" + timestampLogicalType.getUnit());
+                return Optional.empty();
             }
 
             @Override