R/duckdb.R
to_arrow.Rd
This can be used in pipelines that pass data back and forth between Arrow and DuckDB
to_arrow(.data)
the object to be converted
A RecordBatchReader.
RecordBatchReader
library(dplyr) ds <- InMemoryDataset$create(mtcars) ds %>% filter(mpg < 30) %>% to_duckdb() %>% group_by(cyl) %>% summarize(mean_mpg = mean(mpg, na.rm = TRUE)) %>% to_arrow() %>% collect() #> # A tibble: 3 x 2 #> cyl mean_mpg #> <dbl> <dbl> #> 1 4 23.7 #> 2 6 19.7 #> 3 8 15.1