在Spark Java API中从参数类型创建DataType

import org.apache.spark.sql.types.DataType;
import org.apache.spark.sql.types.DataTypes;
import org.apache.spark.sql.types.StructField;
import org.apache.spark.sql.types.StructType;

public class SparkDataTypeExample {
    public static void main(String[] args) {
        // 创建字段类型
        StructField field1 = DataTypes.createStructField("name", DataTypes.StringType, true);
        StructField field2 = DataTypes.createStructField("age", DataTypes.IntegerType, true);

        // 创建数据类型
        StructType schema = DataTypes.createStructType(new StructField[]{field1, field2});

        // 打印数据类型
        System.out.println(schema);
    }
}