pyspark 写入hive

要将 PySpark 数据写入 Hive，需要按照以下步骤操作：

1. 首先，需要在 PySpark 中创建一个 SparkSession 对象：

from pyspark.sql import SparkSession

spark = SparkSession.builder.appName("Write to Hive").enableHiveSupport().getOrCreate()

2. 然后，将数据加载到一个 PySpark DataFrame 中：

data = [("Alice", 25), ("Bob", 30), ("Charlie", 35)]
df = spark.createDataFrame(data, ["Name", "Age"])

3. 接下来，需要将 DataFrame 写入 Hive 表中。在 PySpark 中，可以使用 `saveAsTable()` 方法将 DataFrame 写入 Hive 表：

df.write.mode("overwrite").saveAsTable("myhive.mytable")

这将创建一个名为 `mytable` 的表，并将 DataFrame 中的数据写入该表。

注意，要将数据写入 Hive 表，需要在 PySpark 中启用 Hive 支持。在创建 SparkSession 对象时，使用 `enableHiveSupport()` 方法启用 Hive 支持。

还需要确保 Hive Metastore 服务正在运行，并且 PySpark 配置中指定了 Hive Metastore 的连接信息。