2017-05-05 42 views
2

当我使用sparklyryarn-client方法设法连接到我们的(新)集群后,现在我只能显示默认方案中的表。我如何连接到scheme.table? 使用DBI它正在工作,例如使用以下行: dbGetQuery(sc, "SELECT * FROM scheme.table LIMIT 10") 在HUE中,我可以显示所有方案的所有表格。从sparklyr以外的默认方案(数据库)的访问表

〜克

回答

2

你可以使用一个完全合格的名称注册临时视图:

spark_session(sc) %>% 
    invoke("table", "my_database.my_table") %>% 
    invoke("createOrReplaceTempView", "my_view") 

tbl(sc, "my_view") 

,或者使用sql方法直接与dplyr:tbl切换数据库

spark_session(sc) %>% invoke("sql", "USE my_database") 

和访问表:

tbl(sc, "my_table") 
+0

非常感谢!我使用了第二个选项,这对我来说工作得很好。 – nachti