访问指向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表的主要内容,如果未能解决你的问题,请参考以下文章

volatile类型限定符的认识

获取所有具有绑定值的限定符的bean

无法从直线访问 Spark 2.0 临时表

在 Spark 2.0 中访问向量列时出现 MatchError

《C专家编程》---不知道的那些事

SSIS 处理缺少文本限定符的平面文件