fix: remove unused data types (#122)

We will add additional extension types as and when needed.

Author: mnorbury

lib/src/main/java/io/cloudquery/transformers/TypeTransformer.java

@@ -1,9 +1,7 @@
 package io.cloudquery.transformers;
 
 import io.cloudquery.scalar.Timestamp;
-import io.cloudquery.types.InetType;
 import io.cloudquery.types.JSONType;
-import io.cloudquery.types.ListType;
 import io.cloudquery.types.UUIDType;
 import java.lang.reflect.Field;
 import org.apache.arrow.vector.types.FloatingPointPrecision;
@@ -37,9 +35,6 @@ private static ArrowType transformArrowType(String name, Class<?> type)
         case "java.util.Map" -> {
           return JSONType.INSTANCE;
         }
-        case "java.net.InetAddress" -> {
-          return InetType.INSTANCE;
-        }
         case "java.time.LocalDateTime" -> {
           return Timestamp.dt;
         }
@@ -52,9 +47,7 @@ private static ArrowType transformArrowType(String name, Class<?> type)
             if (componentType.getName().equals("byte")) {
               return ArrowType.Binary.INSTANCE;
             }
-            // if element type is already json just return JSON rather than a list of JSON
-            ArrowType elementType = transformArrowType(name, componentType);
-            return elementType == JSONType.INSTANCE ? elementType : ListType.listOf(elementType);
+            return JSONType.INSTANCE;
           }
           if (!type.isPrimitive()) {
             return JSONType.INSTANCE;

lib/src/main/java/io/cloudquery/types/InetType.java

@@ -12,10 +12,7 @@
 
 import io.cloudquery.schema.Column;
 import io.cloudquery.schema.Table;
-import io.cloudquery.types.InetType;
 import io.cloudquery.types.JSONType;
-import io.cloudquery.types.ListType;
-import java.net.InetAddress;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
 import java.util.List;
@@ -57,7 +54,6 @@ public static final class TestClass {
     private List<Integer> intListCol;
     private String[] stringArrayCol;
     private List<String> stringListCol;
-    private InetAddress inetAddressCol;
     private byte[] byteArrayCol;
     private Object[] anyArrayCol;
     private LocalDateTime timeCol;
@@ -89,11 +85,10 @@ public static final class TestClass {
           Column.builder().name("boolean_col").type(Bool.INSTANCE).build(),
           Column.builder().name("boolean_object_col").type(Bool.INSTANCE).build(),
           Column.builder().name("json_col").type(JSONType.INSTANCE).build(),
-          Column.builder().name("int_array_col").type(ListType.listOf(new Int(64, true))).build(),
+          Column.builder().name("int_array_col").type(JSONType.INSTANCE).build(),
           Column.builder().name("int_list_col").type(JSONType.INSTANCE).build(),
-          Column.builder().name("string_array_col").type(ListType.listOf(Utf8.INSTANCE)).build(),
+          Column.builder().name("string_array_col").type(JSONType.INSTANCE).build(),
           Column.builder().name("string_list_col").type(JSONType.INSTANCE).build(),
-          Column.builder().name("inet_address_col").type(InetType.INSTANCE).build(),
           Column.builder().name("byte_array_col").type(Binary.INSTANCE).build(),
           Column.builder().name("any_array_col").type(JSONType.INSTANCE).build(),
           Column.builder()

lib/src/main/java/io/cloudquery/types/ListType.java

@@ -3,9 +3,7 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 import io.cloudquery.transformers.TypeTransformer.DefaultTypeTransformer;
-import io.cloudquery.types.InetType;
 import io.cloudquery.types.JSONType;
-import io.cloudquery.types.ListType;
 import java.net.InetAddress;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
@@ -98,20 +96,13 @@ public static Stream<Arguments> testArgumentsSource() {
         // Inner class
         Arguments.of("innerClassObjectField", JSONType.INSTANCE),
 
-        // Array field
-        Arguments.of("intArrayField", ListType.listOf(new ArrowType.Int(64, true))),
-        Arguments.of("stringArrayField", ListType.listOf(ArrowType.Utf8.INSTANCE)),
-
         // Time
         Arguments.of(
             "timeField", new ArrowType.Timestamp(TimeUnit.MILLISECOND, ZoneOffset.UTC.getId())),
 
         // Byte
         Arguments.of("byteArrayField", ArrowType.Binary.INSTANCE),
 
-        // Inet
-        Arguments.of("inetField", InetType.INSTANCE),
-
         // Object array
         Arguments.of("objectArrayField", JSONType.INSTANCE));
   }