spark中两个Row如何UNION合并，Java代码实现

在Spark中，可以使用Dataset的union方法将两个Row集合合并成一个。以下是一个示例代码：

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

import java.util.ArrayList;
import java.util.List;

...

// 创建SparkSession对象
SparkSession spark = SparkSession.builder()
    .appName("Java Spark SQL basic example")
    .config("spark.some.config.option", "some-value")
    .getOrCreate();

// 创建第一个Row集合
List<Row> rows1 = new ArrayList<>();
rows1.add(RowFactory.create(1, "John"));
rows1.add(RowFactory.create(2, "Jane"));

// 创建第二个Row集合
List<Row> rows2 = new ArrayList<>();
rows2.add(RowFactory.create(3, "Bob"));
rows2.add(RowFactory.create(4, "Alice"));

// 将两个Row集合合并为一个Dataset<Row>对象
Dataset<Row> dataset = spark.createDataFrame(rows1, schema).union(spark.createDataFrame(rows2, schema));

在上面的示例代码中，首先创建了一个SparkSession对象。然后创建了两个Row集合，分别包含"id"和"name"两个字段的值。最后使用SparkSession的createDataFrame方法将两个Row集合分别转换为DataFrame对象，然后使用union方法将两个DataFrame合并为一个，得到一个包含四条记录的DataFrame对象。其中，"schema"是之前定义的StructType对象，用于指定Row对象的结构。