配置单元查询-

select ...MYUDF(collect_set(col1))..from tableN

这里col1是字符串类型。我想对此传递的collect_set数据执行某些逻辑。
对于用户定义的函数,我将扩展类 UDF 并使用评估方法。当从Hive传递数组时,评估方法的签名应该是什么。我想从UDF返回字符串数组。
public **<returnType>** evaluate(**<collect as what>**)
{
}

最佳答案

ArrayList<Text>(import java.util.ArrayList)

09-26 22:40