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()
}

Alternative:

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

duckdb_write_parquet <- function(.tbl_sql, path) {
  sql_tbl <- 
    .tbl_sql |>
    dbplyr::sql_render()
  
  sql_call <- glue::glue("COPY ({sql_tbl}) TO '{path}' (FORMAT 'parquet', COMPRESSION ZSTD)")
  
  res <- dbExecute(dbplyr::remote_con(.tbl_sql), sql_call)
  
  return(res)
}