我可以使用 hive.metastore.uris 在争吵中。我想要的是通过这个连接连接到配置单元的特定数据库，这样就不需要在查询中向每个表名添加数据库名。有没有办法做到这一点？
应该是这样的代码
SparkSession sparkSession = SparkSession.config("hive.metastore.uris", "thrift://dhdhdkkd136.india.sghjd.com:9083/hive_database")我可以使用 hive.metastore.uris 在争吵中。我想要的是通过这个连接连接到配置单元的特定数据库，这样就不需要在查询中向每个表名添加数据库名。有没有办法做到这一点？
应该是这样的代码
SparkSession sparkSession = SparkSession.config("hive.metastore.uris", "thrift://dhdhdkkd136.india.sghjd.com:9083/hive_database")
1条答案
按热度按时间i34xakig1#
您可以使用可从sparksession访问的catalogapi。
https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.catalog.catalog
你可以打电话给我
sparkSession.catalog.setCurrentDatabase(<db_name>)