访问指向spark 2.0中的数据库限定符的hive表
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了访问指向spark 2.0中的数据库限定符的hive表相关的知识,希望对你有一定的参考价值。
我正在尝试使用spark sql访问指定数据库限定符的hive表。我正在使用sparksession,因为它是2.0或更高的火花。例如,我正在尝试将分区添加到现有表。查询是
sparksession.sql(“ALTER TABLE $ databasename。$ tablename ADD PARTITION(...)LOCATION ...”)
它不会抛出任何错误,但甚至不会创建任何分区。是不是我不能在spark sql中指定databaseName?
答案
use Database
您可以使用最新Spark版本支持命令
sparksession.sql("use $databasename");
sparksession.sql("ALTER TABLE $tablename ADD PARTITION (...) LOCATION ...");
尝试使用上面的代码,这可以解决您的问题。
以上是关于访问指向spark 2.0中的数据库限定符的hive表的主要内容,如果未能解决你的问题,请参考以下文章