From 24fdde909f5744d85299b281cc1fc834cbe97d10 Mon Sep 17 00:00:00 2001
From: Pablo Pardo Garcia <pablo@glassflow.dev>
Date: Wed, 22 Oct 2025 15:52:44 +0200
Subject: [PATCH 1/2] Add support for more array data types

- Add ARRAY_FLOAT32, ARRAY_FLOAT64, ARRAY_BOOL array types
- Add ARRAY_UINT8, ARRAY_UINT16, ARRAY_UINT32, ARRAY_UINT64 array types
- Add ARRAY_LC_* variants for all supported types
- Update FLOAT mapping to include both FLOAT32 and FLOAT64
- Expand ARRAY mapping to include all new array data types
---
 src/glassflow/etl/models/data_types.py | 42 +++++++++++++++++++++++++-
 1 file changed, 41 insertions(+), 1 deletion(-)

diff --git a/src/glassflow/etl/models/data_types.py b/src/glassflow/etl/models/data_types.py
index a915f95..981c049 100644
--- a/src/glassflow/etl/models/data_types.py
+++ b/src/glassflow/etl/models/data_types.py
@@ -58,6 +58,26 @@ class ClickhouseDataType(CaseInsensitiveStrEnum):
     ARRAY_INT16 = "Array(Int16)"
     ARRAY_INT32 = "Array(Int32)"
     ARRAY_INT64 = "Array(Int64)"
+    ARRAY_FLOAT32 = "Array(Float32)"
+    ARRAY_FLOAT64 = "Array(Float64)"
+    ARRAY_BOOL = "Array(Bool)"
+    ARRAY_UINT8 = "Array(UInt8)"
+    ARRAY_UINT16 = "Array(UInt16)"
+    ARRAY_UINT32 = "Array(UInt32)"
+    ARRAY_UINT64 = "Array(UInt64)"
+    ARRAY_LC_STRING = "Array(LowCardinality(String))"
+    ARRAY_LC_INT8 = "Array(LowCardinality(Int8))"
+    ARRAY_LC_INT16 = "Array(LowCardinality(Int16))"
+    ARRAY_LC_INT32 = "Array(LowCardinality(Int32))"
+    ARRAY_LC_INT64 = "Array(LowCardinality(Int64))"
+    ARRAY_LC_UINT8 = "Array(LowCardinality(UInt8))"
+    ARRAY_LC_UINT16 = "Array(LowCardinality(UInt16))"
+    ARRAY_LC_UINT32 = "Array(LowCardinality(UInt32))"
+    ARRAY_LC_UINT64 = "Array(LowCardinality(UInt64))"
+    ARRAY_LC_FLOAT32 = "Array(LowCardinality(Float32))"
+    ARRAY_LC_FLOAT64 = "Array(LowCardinality(Float64))"
+    ARRAY_LC_DATETIME = "Array(LowCardinality(DateTime))"
+    ARRAY_LC_FIXEDSTRING = "Array(LowCardinality(FixedString))"
 
 
 kafka_to_clickhouse_data_type_mappings = {
@@ -100,7 +120,7 @@ class ClickhouseDataType(CaseInsensitiveStrEnum):
     KafkaDataType.UINT32: [ClickhouseDataType.UINT32],
     KafkaDataType.UINT64: [ClickhouseDataType.UINT64],
     KafkaDataType.UINT8: [ClickhouseDataType.UINT8],
-    KafkaDataType.FLOAT: [ClickhouseDataType.FLOAT64],
+    KafkaDataType.FLOAT: [ClickhouseDataType.FLOAT32, ClickhouseDataType.FLOAT64],
     KafkaDataType.FLOAT32: [ClickhouseDataType.FLOAT32, ClickhouseDataType.LC_FLOAT32],
     KafkaDataType.FLOAT64: [
         ClickhouseDataType.FLOAT64,
@@ -118,5 +138,25 @@ class ClickhouseDataType(CaseInsensitiveStrEnum):
         ClickhouseDataType.ARRAY_INT16,
         ClickhouseDataType.ARRAY_INT32,
         ClickhouseDataType.ARRAY_INT64,
+        ClickhouseDataType.ARRAY_FLOAT32,
+        ClickhouseDataType.ARRAY_FLOAT64,
+        ClickhouseDataType.ARRAY_BOOL,
+        ClickhouseDataType.ARRAY_UINT8,
+        ClickhouseDataType.ARRAY_UINT16,
+        ClickhouseDataType.ARRAY_UINT32,
+        ClickhouseDataType.ARRAY_UINT64,
+        ClickhouseDataType.ARRAY_LC_STRING,
+        ClickhouseDataType.ARRAY_LC_INT8,
+        ClickhouseDataType.ARRAY_LC_INT16,
+        ClickhouseDataType.ARRAY_LC_INT32,
+        ClickhouseDataType.ARRAY_LC_INT64,
+        ClickhouseDataType.ARRAY_LC_UINT8,
+        ClickhouseDataType.ARRAY_LC_UINT16,
+        ClickhouseDataType.ARRAY_LC_UINT32,
+        ClickhouseDataType.ARRAY_LC_UINT64,
+        ClickhouseDataType.ARRAY_LC_FLOAT32,
+        ClickhouseDataType.ARRAY_LC_FLOAT64,
+        ClickhouseDataType.ARRAY_LC_DATETIME,
+        ClickhouseDataType.ARRAY_LC_FIXEDSTRING,
     ],
 }

From 290c73d900a4bd4c9f519ff96022b126e0dd67ae Mon Sep 17 00:00:00 2001
From: "github-actions[bot]" <github-actions[bot]@users.noreply.github.com>
Date: Wed, 22 Oct 2025 13:54:24 +0000
Subject: [PATCH 2/2] chore: bump version to 3.3.0

---
 VERSION | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/VERSION b/VERSION
index e4604e3..15a2799 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-3.2.1
+3.3.0