我想知道在R的arrow工作流程中是否可以发送一个关于duckdb的SQL查询.
我知道它的意图是使用dplyr个动词，但有一些动词翻译不流畅，代码在dplyr后端工作，但不是duckdb或arrow.
我想在呼叫期间使用直接的SQL查询，类似于下面的示例:
library(duckdb)
library(arrow)
library(dplyr)
# Open dataset using year,month folder partition
ds <- arrow::open_dataset("nyc-taxi", partitioning = c("year", "month"))
ds %>%
# Pass off to DuckDB
to_duckdb() |>
SQL_QUERY("SELECT * LIMIT 100") |> # <- something like this
collect()
根据您要完成的任务，您可以将SQL查询片段与这dplyr个谓词一起使用:
ds |>
to_duckdb() |>
filter(sql("vendor_name = 'VTS' AND year = 2009 AND month = 1")) |>
collect()
您可以在dbplyr vignettes种方法之一中找到有关此方法的更多信息.
这种方法不适用于更复杂的查询.但是，您可以使用to_duckdb()返回的信息与DBI包一起发送完整的SQL查询:
db_tbl <- ds |>
to_duckdb(table_name = "nyc_tbl")
con <- db_tbl$src$con
dbGetQuery(con, "SELECT * FROM 'nyc_tbl' LIMIT 100")