从 DuckDB 连接创建 Arrow 对象

这可以在 Arrow 和 DuckDB 之间来回传递数据的管道中使用。

用法

to_arrow(.data)

参数

.data

要转换的对象

值

一个 RecordBatchReader。

详细信息

请注意，您只能在此函数的结果上调用一次 collect() 或 compute()。 为了解决此限制，您应该仅在管道的最后一步调用 collect()，或者在此结果上调用 as_arrow_table() 以将整个表物化到内存中。

示例

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