我正在使用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]
.
任何帮助都将不胜感激。
1条答案
按热度按时间qf9go6mv1#