先将Dataset<Row>转换为JavaRDD<Row>，然后再转换为数据帧时的RuntimeException

Dataset<Row> dataset = ... // 原始的Dataset<Row>
JavaRDD<Row> javaRDD = dataset.toJavaRDD();

import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.RowFactory;
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 DatasetToDataFrameExample {
    public static void main(String[] args) {
        // 创建SparkSession
        SparkSession spark = SparkSession.builder()
                .appName("Dataset to DataFrame Example")
                .master("local")
                .getOrCreate();

        // 创建示例数据集
        Dataset<Row> dataset = spark.createDataFrame(
                spark.sparkContext().parallelize(
                        Arrays.asList(
                                RowFactory.create(1, "John"),
                                RowFactory.create(2, "Jane"),
                                RowFactory.create(3, "Alice")
                        )
                ),
                DataTypes.createStructType(Arrays.asList(
                        DataTypes.createStructField("id", DataTypes.IntegerType, false),
                        DataTypes.createStructField("name", DataTypes.StringType, false)
                ))
        );

        // 将Dataset<Row>转换为JavaRDD<Row>
        JavaRDD<Row> javaRDD = dataset.toJavaRDD();

        // 定义数据帧的结构
        StructType schema = DataTypes.createStructType(Arrays.asList(
                DataTypes.createStructField("id", DataTypes.IntegerType, false),
                DataTypes.createStructField("name", DataTypes.StringType, false)
        ));

        try {
            // 将JavaRDD<Row>转换为数据帧
            Dataset<Row> dataFrame = spark.createDataFrame(javaRDD, schema);

            // 打印数据帧的内容
            dataFrame.show();
        } catch (RuntimeException e) {
            // 处理转换过程中可能出现的RuntimeException
            System.out.println("Failed to convert JavaRDD<Row> to DataFrame: " + e.getMessage());
        }

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