Spark Java向Hive表追加数据

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

List<Row> data = Arrays.asList(
        RowFactory.create("John", 25),
        RowFactory.create("Jane", 30)
);

StructType schema = new StructType()
        .add("name", DataTypes.StringType)
        .add("age", DataTypes.IntegerType);

Dataset<Row> df = spark.createDataFrame(data, schema);

df.createOrReplaceTempView("temp_table");

spark.sql("INSERT INTO TABLE hive_table SELECT * FROM temp_table");