使用spark sql连接到配置单元

ajsxfq5m  于 2021-06-26  发布在  Hive
关注(0)|答案(1)|浏览(580)

我正在使用sparksql运行配置单元查询。我做了一个Hive上下文对象

val hiveContext = new org.apache.spark.sql.hive.HiveContext(sc);

当我尝试运行命令时:

hiveContext.sql("use db_name");

hiveContext.hiveql("use db_name");

它不起作用。上面写着 database not found. 当我想跑的时候

val db = hiveContext.hiveql("show databases");
db.collect.foreach(println);

它什么也没印出来。只是指纹 [default] .
任何帮助都将不胜感激。

qf9go6mv

qf9go6mv1#

hiveContext.sql("SELECT * FROM database.table")

相关问题