【发布时间】:2018-11-27 14:32:13
【问题描述】:
我正在查看this ticket,不明白 Spark 是否支持任何语言(Scala、Python、Java、R)的 2.3+ 版本的 UDT?
我有这样的课
Class Test{
string name;
int age;
}
而我的 UDF 方法是:
public Test UDFMethod(string name, int age){
Test ob = new Test();
ob.name = name;
ob.age = age;
}
Spark 查询示例
Select *, UDFMethod(name, age) From SomeTable;
现在UDFMethod(name, age) 将返回测试对象。那么在使用SQLUserDefinedType 标记并扩展UserDefinedType 类之后,这将在Spark SQL 中工作吗?
UserDefinedType 类在 Spark 2.0 中被设为私有。我只想知道 Spark 2.3+ 是否支持 UDT。如果是,最好使用UserDefinedType 或UDTRegisteration。到目前为止,两者都是 spark 私有的。
【问题讨论】:
标签: apache-spark apache-spark-sql