spark讲hive写入

可以通过Spark SQL来将数据写入Hive表中。首先要创建一个HiveContext，然后将数据加载到DataFrame中，最后调用write方法将数据写入Hive表中，示例代码如下：

from pyspark.sql import SparkSession
from pyspark.sql import HiveContext

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

hive_context = HiveContext(spark.sparkContext)

# 加载数据到DataFrame
data = spark.read.format("csv").option("header", "true").load("data.csv")

# 将数据写入Hive表中
data.write.mode("overwrite").saveAsTable("my_table")

其中，enableHiveSupport()方法会启用Hive支持，getOrCreate()方法会创建一个SparkSession对象。load()方法用于加载数据到DataFrame中，option()方法用于设置CSV文件的一些选项。write()方法用于将数据写入Hive表中，mode("overwrite")表示覆盖已有的数据，saveAsTable()方法用于保存到Hive表中。