From 7f53b8a2b58b5473dc6bb865967a16c7e8949472 Mon Sep 17 00:00:00 2001 From: Matt Topol Date: Tue, 23 Jul 2024 07:22:06 -0700 Subject: [PATCH] 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 0e66931dd2..8b80ee49d8 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(?)"