如何在 hive udf 中使用 collect_set 的结果 - 评估方法?

Posted

技术标签:

【中文标题】如何在 hive udf 中使用 collect_set 的结果 - 评估方法?【英文标题】:how to use result of collect_set in hive udf - evaluate method? 【发布时间】:2017-03-16 13:06:24 【问题描述】:

Hive 查询 -

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

这里 col1 是字符串类型。我想对这个传递的 collect_set 数据执行某些逻辑。 对于用户定义的函数,我正在扩展类 UDF 并使用评估方法。当数组从 hive 传递时,评估方法的 签名 应该是什么。我想从 UDF 返回字符串数组。

public **<returnType>** evaluate(**<collect as what>**)


【问题讨论】:

【参考方案1】:

ArrayList&lt;Text&gt; (import java.util.ArrayList)

【讨论】:

以上是关于如何在 hive udf 中使用 collect_set 的结果 - 评估方法?的主要内容,如果未能解决你的问题,请参考以下文章

如何在Hive&Impala中使用UDF

0011-如何在Hive & Impala中使用UDF

hive编程 | 使用mvn构造udf函数

hive编程 | 使用mvn构造udf函数

hive编程 | 使用mvn构造udf函数

Hive中实现group concat功能(不用udf)