spark on hive local模式使用元数据连接的方式查询hive

在本地模式下，可以使用Spark连接Hive元数据来查询Hive。具体步骤如下：

1. 首先，需要在Spark中添加Hive支持。可以在SparkSession中设置hive支持，如下所示：

val spark = SparkSession.builder()
  .appName("Spark Hive Example")
  .config("spark.sql.warehouse.dir", "/user/hive/warehouse")
  .enableHiveSupport()
  .getOrCreate()

2. 然后，需要创建HiveContext对象，用于连接Hive元数据。可以使用以下代码创建HiveContext对象：

val hiveContext = new org.apache.spark.sql.hive.HiveContext(spark.sparkContext)

3. 接下来，可以使用HiveContext对象查询Hive表。例如，可以使用以下代码查询Hive表中的数据：

val df = hiveContext.sql("SELECT * FROM mytable")

其中，mytable是Hive中的表名。

4. 最后，可以使用DataFrame API对查询结果进行处理。例如，可以使用以下代码将查询结果保存到HDFS中：

df.write.format("parquet").save("hdfs://localhost:9000/user/hive/warehouse/mytable")

以上就是在Spark on Hive本地模式下使用元数据连接的方式查询Hive的步骤。