This is an automated email from the ASF dual-hosted git repository.
zeroshade 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 7f53b8a2b feat(go/adbc/driver/snowflake): use vectorized scanner for
bulk ingest (#2025)
7f53b8a2b is described below
commit 7f53b8a2b58b5473dc6bb865967a16c7e8949472
Author: Matt Topol <[email protected]>
AuthorDate: Tue Jul 23 07:22:06 2024 -0700
feat(go/adbc/driver/snowflake): use vectorized scanner for bulk ingest
(#2025)
Closes #2005
---
go/adbc/driver/snowflake/bulk_ingestion.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/go/adbc/driver/snowflake/bulk_ingestion.go
b/go/adbc/driver/snowflake/bulk_ingestion.go
index 0e66931dd..8b80ee49d 100644
--- a/go/adbc/driver/snowflake/bulk_ingestion.go
+++ b/go/adbc/driver/snowflake/bulk_ingestion.go
@@ -45,7 +45,7 @@ import (
const (
bindStageName = "ADBC$BIND"
- createTemporaryStageStmt = "CREATE OR REPLACE TEMPORARY STAGE " +
bindStageName + " FILE_FORMAT = (TYPE = PARQUET USE_LOGICAL_TYPE = TRUE
BINARY_AS_TEXT = FALSE)"
+ createTemporaryStageStmt = "CREATE OR REPLACE TEMPORARY STAGE " +
bindStageName + " FILE_FORMAT = (TYPE = PARQUET USE_LOGICAL_TYPE = TRUE
BINARY_AS_TEXT = FALSE USE_VECTORIZED_SCANNER=TRUE REPLACE_INVALID_CHARACTERS =
TRUE)"
putQueryTmpl = "PUT 'file:///tmp/placeholder/%s' @" +
bindStageName + " OVERWRITE = TRUE"
copyQuery = "COPY INTO IDENTIFIER(?) FROM @" +
bindStageName + " MATCH_BY_COLUMN_NAME = CASE_INSENSITIVE"
countQuery = "SELECT COUNT(*) FROM IDENTIFIER(?)"
