add case for pyarrow when type is null

apache · Feb 21, 2025 · 1515e44 · 1515e44
1 parent 0008e3b
commit 1515e44
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py
@@ -1213,6 +1213,8 @@ def primitive(self, primitive: pa.DataType) -> PrimitiveType:
         elif pa.types.is_fixed_size_binary(primitive):
             primitive = cast(pa.FixedSizeBinaryType, primitive)
             return FixedType(primitive.byte_width)
+        elif pa.types.is_null(primitive):
+            return UnknownType()
 
         raise TypeError(f"Unsupported type: {primitive}")