来自特定数据库的 sparklyr spark_read_table

Question

我的数据库管理员已将我的表从默认表移至另一个数据库（名为 marketing）。我下面的查询不再有效。

这是完成的。

CREATE OR REPLACE VIEW marketing.scv_snap AS select * from delta.`dbfs:/mnt/dataLake/xxx/xxx`;
select * from marketing.scv_snap limit 10

我无法在下面的 spark_read_table 中包含 'marketing' 路径；感谢您的帮助

spark_read_table(sc, 'scv_tbl', memory = FALSE)

Answer 1

您需要使用tbl_change_db函数来更改当前数据库：

tbl_change_db(sc, "marketing")
data <- spark_read_table(sc, "scv_tbl")

sparklyr spark_read_table from a specific database