Spark java :创建具有给定模式的新数据集

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
import org.apache.spark.sql.types.DataTypes;
import org.apache.spark.sql.types.StructField;
import org.apache.spark.sql.types.StructType;

public class SparkJavaExample {
    public static void main(String[] args) {
        // 创建SparkSession对象
        SparkSession spark = SparkSession.builder()
                .appName("SparkJavaExample")
                .master("local")
                .getOrCreate();

        // 定义数据集的模式
        StructType schema = DataTypes.createStructType(new StructField[] {
                DataTypes.createStructField("name", DataTypes.StringType, true),
                DataTypes.createStructField("age", DataTypes.IntegerType, true),
                DataTypes.createStructField("city", DataTypes.StringType, true)
        });

        // 创建具有给定模式的新数据集
        Dataset<Row> dataset = spark.createDataFrame(
                spark.sparkContext().emptyRDD(), schema);

        // 打印数据集的模式
        dataset.printSchema();

        // 关闭SparkSession对象
        spark.close();
    }
}