如何查询 hive 分区表的某个分区数据是否存在

假如以 date 和 job_id 两个字段作为分区

select count(*) from profile.user_crowd where date = 20220304 and job_id = 12345

使用 spark 判断结果

val date = 20220304
val jobId = 12345
val sql = s"select count(*) from profile.user_crowd_test where date = ${date} and job_id = ${jobId}"
val rows = sparkSql.sql(sql).collect()
if (rows(0).getLong(0) > 0) {
// 存在数据
}