spark sql数据源--hive

使用的是idea编辑器

spark sql从hive中读取数据的步骤:1.引入hive的jar包

                                                          2.将hive-site.xml放到resource下

                3.spark sql声明对hive的支持

案例:

def main(args: Array[String]): Unit = {
val spark: SparkSession = SparkSession
.builder()
.appName(s"${this.getClass.getSimpleName}")
.master("local[*]")
.enableHiveSupport()
.getOrCreate()

//指明要使用的数据库
spark.sql("use zhangqi")
spark.sql("select * from monitor_camera_info limit 10").show()
//关闭资源
spark.close()
原文地址:https://www.cnblogs.com/yezihan/p/11563108.html