duckdb_write_parquet.R

library(duckdb)
library(DBI)
library(dbplyr)

duckdb_write_parquet <- function(tbl_obj, filename){
  library(tictoc)
  library(glue)
  tbl_object$src$con -> con
  con %>% dbExecute("SET autoinstall_known_extensions=1;")
  con %>% dbExecute("SET autoload_known_extensions=1;")
  tic();dbExecute(con, glue("COPY ({sql_render(tbl_obj)}) TO '{filename}' (FORMAT 'parquet', COMPRESSION ZSTD);"));toc()
}