java 中spark3初始化dataset row

在Java中，初始化Spark 3 Dataset的Row对象可以使用以下代码：

import org.apache.spark.sql.Row;
import org.apache.spark.sql.types.*;

// 定义结构化数据的类型
StructType schema = new StructType(new StructField[] {
  new StructField("name", DataTypes.StringType, false, Metadata.empty()),
  new StructField("age", DataTypes.IntegerType, false, Metadata.empty())
});

// 创建Row对象
Row row = RowFactory.create("John", 30);

// 创建Dataset
Dataset<Row> dataset = spark.createDataFrame(Collections.singletonList(row), schema);

这里首先需要定义结构化数据的类型，然后使用RowFactory.create()方法创建Row对象，最后使用spark.createDataFrame()方法将Row对象转换为Dataset。注意，如果有多条记录，需要将所有Row对象添加到List中。