如何在UDF中传递Row？

我正在用Java编写UDF。

我想对它进行更复杂的操作DateSet。为此，我认为我需要DataSet作为输入传递给我的UDF并返回输出。这是我的代码：

UDF1,String> myUDF = new UDF1,String>() {

        public String call(Dataset<Row> input) throws Exception {
            System.out.println(input);
            return "test";
        }
        };

       // Register the UDF with our SQLContext
        spark.udf().register("myUDF", myUDF, DataTypes.StringType); {

但是当我去尝试使用myUDF时，似乎callUDF函数只接受a Column而不是a DataSet。

任何人都可以帮助我如何DataSet将输入参数传递给UDF？有没有其他方法可以在Spark SQL中调用我的UDF？