@@ -51,7 +51,7 @@ def pyarrow2athena( # noqa: PLR0911,PLR0912
51
51
return pyarrow2athena (dtype = dtype .value_type , ignore_null = ignore_null )
52
52
if pa .types .is_decimal (dtype ):
53
53
return f"decimal({ dtype .precision } ,{ dtype .scale } )"
54
- if pa .types .is_list (dtype ):
54
+ if pa .types .is_list (dtype ) or pa . types . is_large_list ( dtype ) :
55
55
return f"array<{ pyarrow2athena (dtype = dtype .value_type , ignore_null = ignore_null )} >"
56
56
if pa .types .is_struct (dtype ):
57
57
return (
@@ -100,7 +100,7 @@ def pyarrow2redshift( # noqa: PLR0911,PLR0912
100
100
return f"DECIMAL({ dtype .precision } ,{ dtype .scale } )"
101
101
if pa .types .is_dictionary (dtype ):
102
102
return pyarrow2redshift (dtype = dtype .value_type , string_type = string_type )
103
- if pa .types .is_list (dtype ) or pa .types .is_struct (dtype ) or pa .types .is_map (dtype ):
103
+ if pa .types .is_list (dtype ) or pa .types .is_struct (dtype ) or pa .types .is_map (dtype ) or pa . types . is_large_list ( dtype ) :
104
104
return "SUPER"
105
105
raise exceptions .UnsupportedType (f"Unsupported Redshift type: { dtype } " )
106
106
@@ -213,7 +213,7 @@ def pyarrow2postgresql( # noqa: PLR0911
213
213
return pyarrow2postgresql (dtype = dtype .value_type , string_type = string_type )
214
214
if pa .types .is_binary (dtype ):
215
215
return "BYTEA"
216
- if pa .types .is_list (dtype ):
216
+ if pa .types .is_list (dtype ) or pa . types . is_large_list ( dtype ) :
217
217
return pyarrow2postgresql (dtype = dtype .value_type , string_type = string_type ) + "[]"
218
218
raise exceptions .UnsupportedType (f"Unsupported PostgreSQL type: { dtype } " )
219
219
0 commit comments