Merge pull request #86 from Altinity/fix_timestamp_partitioning

Use columnMeta.getPrimitiveType() so that the logical type is kept fo…

Author: shyiko

ice/src/main/java/com/altinity/ice/cli/internal/iceberg/Partitioning.java

@@ -141,13 +141,19 @@ public static void apply(UpdatePartitionSpec op, List<Main.IcePartition> columns
       boolean same = true;
 
       for (BlockMetaData block : blocks) {
-        Statistics<?> stats =
+        ColumnChunkMetaData columnMeta =
             block.getColumns().stream()
                 .filter(c -> c.getPath().toDotString().equals(sourceName))
                 .findFirst()
-                .map(ColumnChunkMetaData::getStatistics)
                 .orElse(null);
 
+        if (columnMeta == null) {
+          same = false;
+          break;
+        }
+
+        Statistics<?> stats = columnMeta.getStatistics();
+
         if (stats == null
             || !stats.hasNonNullValue()
             || stats.genericGetMin() == null
@@ -159,7 +165,7 @@ public static void apply(UpdatePartitionSpec op, List<Main.IcePartition> columns
         Transform<Object, Object> transform = (Transform<Object, Object>) field.transform();
         SerializableFunction<Object, Object> boundTransform = transform.bind(type);
 
-        PrimitiveType parquetType = stats.type();
+        PrimitiveType parquetType = columnMeta.getPrimitiveType();
 
         Comparable<?> parquetMin = stats.genericGetMin();
         var min = fromParquetPrimitive(type, parquetType, parquetMin);