Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion go/adbc/driver/snowflake/record_reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -351,7 +351,12 @@ func rowTypesToArrowSchema(_ context.Context, ld gosnowflake.ArrowStreamLoader,
Scale: int32(srcMeta.Scale),
}
} else {
fields[i].Type = arrow.PrimitiveTypes.Int64
// Check scale to determine if this is an integer or decimal
if srcMeta.Scale == 0 {
fields[i].Type = arrow.PrimitiveTypes.Int64
} else {
fields[i].Type = arrow.PrimitiveTypes.Float64
}
}
case "real":
fields[i].Type = arrow.PrimitiveTypes.Float64
Expand Down
Loading