我有一個 spark 數(shù)據(jù)集的列（在 java 中），我希望該列的所有值成為新列的列名（新列可以用常量值填充）。For example I have:+------------+|    Column  | +------------+| a          | | b          || c          |+------------+And I want: +------+----+----+---+|Column| a  |  b | c |+------+----+----+---+| a    | 0  | 0  |0  || b    | 0  | 0  |0  || c    | 0  | 0  |0  |+------+----+----+---+我試過的是：public class test{    static SparkSession spark = SparkSession.builder().appName("Java")            .config("spark.master", "local").getOrCreate();    static Dataset<Row> dataset = spark.emptyDataFrame();    public Dataset<Row> test(Dataset<Row> ds, SparkSession spark) {        SQLContext sqlContext = new SQLContext(spark);        sqlContext.udf().register("add", add, DataTypes.createArrayType(DataTypes.StringType));        ds = ds.withColumn("substrings", functions.callUDF("add", ds.col("Column")));        return ds;    }    private static UDF1 addSubstrings = new UDF1<String, String[]>() {        public String[] call(String str) throws Exception {            dataset = dataset.withColumn(str, functions.lit(0));            String[] a = {"placeholder"};            return a;        }    };}我的問題是，有時我得到正確的結果，有時卻沒有（未添加列）。我真的不明白為什么。我正在尋找一種將數(shù)據(jù)集傳遞給 UDF 的方法，但我不知道該怎么做。目前我正在通過使用列的 collectAsList() 來解決它，然后迭代 Arraylist 從而添加新列。但這真的很低效，因為我的數(shù)據(jù)太多了。