Clean up code

baremaps-core/src/main/java/org/apache/baremaps/workflow/tasks/ImportGeoParquet.java

@@ -73,7 +73,6 @@ public void execute(WorkflowContext context) throws Exception {
     var postgresDataStore = new PostgresDataStore(dataSource);
     for (var name : geoParquetDataStore.list()) {
       var geoParquetTable = (GeoParquetDataTable) geoParquetDataStore.get(name);
-      // TODO : How can we apply a different SRID for each column based on the geometry
       var projectionTransformer =
           new ProjectionTransformer(geoParquetTable.srid("geometry"), databaseSrid);
       var rowTransformer =

baremaps-geoparquet/src/main/java/org/apache/baremaps/geoparquet/GeoParquetReader.java

@@ -100,24 +100,8 @@ private synchronized Map<FileStatus, FileInfo> files() throws URISyntaxException
         FileSystem fs = FileSystem.get(uri, configuration);
         FileStatus[] fileStatuses = fs.globStatus(new Path(uri));
 
-        for (FileStatus fileStatus : fileStatuses) {
-          Path filePath = fileStatus.getPath();
-          ParquetFileReader reader = ParquetFileReader.open(configuration, filePath);
-          Long recordCount = reader.getRecordCount();
-          MessageType messageType = reader.getFileMetaData().getSchema();
-          Map<String, String> keyValueMetadata = reader.getFileMetaData().getKeyValueMetaData();
-          GeoParquetMetadata geoParquetMetadata = null;
-          GeoParquetGroup.Schema geoParquetSchema = null;
-          if (keyValueMetadata.containsKey("geo")) {
-            ObjectMapper objectMapper = new ObjectMapper();
-            objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
-            geoParquetMetadata =
-                objectMapper.readValue(keyValueMetadata.get("geo"), GeoParquetMetadata.class);
-            geoParquetSchema =
-                GeoParquetGroupFactory.createGeoParquetSchema(messageType, geoParquetMetadata);
-          }
-          files.put(fileStatus, new FileInfo(fileStatus, recordCount, keyValueMetadata, messageType,
-              geoParquetMetadata, geoParquetSchema));
+        for (FileStatus file : fileStatuses) {
+          files.put(file, buildFileInfo(file));
         }
 
         // Verify that the files all have the same schema
@@ -126,12 +110,12 @@ private synchronized Map<FileStatus, FileInfo> files() throws URISyntaxException
           if (commonMessageType == null) {
             commonMessageType = entry.messageType;
           } else if (!commonMessageType.equals(entry.messageType)) {
-            throw new RuntimeException("The files do not have the same schema");
+            throw new GeoParquetException("The files do not have the same schema");
           }
         }
       }
     } catch (IOException e) {
-      throw new RuntimeException("IOException while attempting to list files.", e);
+      throw new GeoParquetException("IOException while attempting to list files.", e);
     }
     return files;
   }

baremaps-geoparquet/src/main/java/org/apache/baremaps/geoparquet/data/GeoParquetGroupImpl.java

@@ -278,6 +278,7 @@ private void appendToString(StringBuilder builder, String indent) {
     }
   }
 
+  @Override
   public List<Primitive> getValues(int fieldIndex) {
     return (List<Primitive>) data[fieldIndex];
   }