我正在尝试使用sparksql访问指定数据库限定符的配置单元表。我正在使用sparksession，因为它是spark 2.0或更高版本。例如，我正在尝试向现有表添加分区。查询是
sparksession.sql（“alter table$databasename.$tablename add partition（…）location…”）
它不会抛出任何错误，甚至不会创建任何分区。是不是我不能在sparksql中指定databasename？
我正在尝试使用sparksql访问指定数据库限定符的配置单元表。我正在使用sparksession，因为它是spark 2.0或更高版本。例如，我正在尝试向现有表添加分区。查询是
sparksession.sql（“alter table$databasename.$tablename add partition（…）location…”）
它不会抛出任何错误，甚至不会创建任何分区。是不是我不能在sparksql中指定databasename？
1条答案
按热度按时间2nc8po8w1#
您可以使用的最新spark版本支持此命令
尝试使用上面的代码这可以解决你的问题。