spark如何连接hive

你可以使用Spark JDBC连接器连接Hive。具体步骤如下：

1.通过运行下面的命令启用Hive元数据：

$HIVE_HOME/bin/schematool -initSchema -dbType derby

2.在Spark 2.0及更高版本中，您可以使用SparkSession将Spark与Hive连接：

val spark = SparkSession.builder().appName("Spark Hive Example").master("local[*]")
                .config("hive.metastore.uris", "thrift://localhost:9083")
                .enableHiveSupport().getOrCreate()

其中，hive.metastore.uris指定了Hive的metastore的URI地址。

3.在Spark 1.6及更低版本中，您需要使用HiveContext：

val sc = new SparkContext("local[*]", "Spark Hive Example")
val hiveContext = new HiveContext(sc)
hiveContext.setConf("hive.metastore.uris", "thrift://localhost:9083")

4.您可以使用HiveQL语句在Spark中查询Hive表，例如：

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

其中，mytable是您在Hive中创建的表的名称。

请注意，在使用Spark连接Hive时，您需要确保您的Spark和Hive版本兼容。