scala - 检查 Metastore 以了解 Spark 中的表可用性

Question

在使用以下选择查询之前，我想检查该表是否在特定的配置单元数据库中可用。如何从元存储中获取信息。

sparkSession.sql("select * from db_name.table_name")

标签： scalaapache-sparkhivehive-metastore

Answer 1

您可以在对表运行操作之前运行以下命令

 sparkSession.sql("use databaseName");
 val df = sparkSession.sql("show tables like 'tableName'")
 if(df.head(1).isEmpty == false){
//write the code
}