This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-adbc.git
The following commit(s) were added to refs/heads/main by this push:
new de124fb4 fix(go/adbc/driver/snowflake): fix failing integration tests
(#888)
de124fb4 is described below
commit de124fb442dc74f6e3f1a29715d421c4cfbcf3ff
Author: Matt Topol <[email protected]>
AuthorDate: Fri Jul 7 16:27:09 2023 -0400
fix(go/adbc/driver/snowflake): fix failing integration tests (#888)
Fixes #885
---
go/adbc/driver/snowflake/record_reader.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/go/adbc/driver/snowflake/record_reader.go
b/go/adbc/driver/snowflake/record_reader.go
index 081127d7..0434674b 100644
--- a/go/adbc/driver/snowflake/record_reader.go
+++ b/go/adbc/driver/snowflake/record_reader.go
@@ -133,7 +133,7 @@ func getTransformer(sc *arrow.Schema, ld
gosnowflake.ArrowStreamLoader) (*arrow.
tb.Append(arrow.Timestamp(time.Unix(epoch[i], int64(fraction[i])).UnixNano()))
}
} else {
- for i, t := range
a.(*array.Timestamp).TimestampValues() {
+ for i, t := range
a.(*array.Int64).Int64Values() {
if a.IsNull(i) {
tb.AppendNull()
continue
@@ -166,7 +166,7 @@ func getTransformer(sc *arrow.Schema, ld
gosnowflake.ArrowStreamLoader) (*arrow.
tb.Append(arrow.Timestamp(time.Unix(epoch[i], int64(fraction[i])).UnixNano()))
}
} else {
- for i, t := range
a.(*array.Timestamp).TimestampValues() {
+ for i, t := range
a.(*array.Int64).Int64Values() {
if a.IsNull(i) {
tb.AppendNull()
continue
