Skip to content

Commit 1bc6e00

Browse files
committed
uuid?
1 parent 6b49a12 commit 1bc6e00

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

plugins/destination/duckdb/client/transform.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,9 @@ func transformArray(arr arrow.Array) arrow.Array {
2121
}
2222

2323
switch arr := arr.(type) {
24-
case *types.UUIDArray, *types.InetArray, *types.MACArray, *types.JSONArray:
24+
case *types.UUIDArray:
25+
return arr.Storage()
26+
case *types.InetArray, *types.MACArray, *types.JSONArray:
2527
return transformToStringArray(arr)
2628
case *array.Uint8:
2729
return transformUint8ToUint32Array(arr)

plugins/destination/duckdb/client/types.go

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,10 +28,7 @@ func transformTypeForWriting(dt arrow.DataType) arrow.DataType {
2828
return arrow.ListOf(transformTypeForWriting(dt.Elem()))
2929
case *arrow.MapType:
3030
return arrow.ListOf(transformTypeForWriting(dt.ValueType()))
31-
}
32-
33-
switch dt := duckDBToArrow(arrowToDuckDB(dt)).(type) {
34-
case *types.UUIDType, *types.JSONType:
31+
case *types.JSONType:
3532
return arrow.BinaryTypes.String
3633
default:
3734
return dt

0 commit comments

Comments
 (0)