使用配置单元表的配置单元UDF

Question

我在java中开发了一个工作正常的配置单元udf，我的函数返回输入与配置单元表中列之间的最佳匹配，因此它有以下简化的伪代码：

class myudf  extends udf{

    evaluate(Text input){

        getNewHiveConnection(); //i want to replace this by getCurrentHiveUserConnetion();
        executeHiveQuery(input);
        return something;
}

我的问题是，如果这个函数是由Hive调用的，为什么我需要在代码中连接到Hive？我可以使用使用我的功能的用户所连接的当前连接吗？

Answer 1

如果希望在查询中从整个列返回最接近的匹配项，可以将其视为某种聚合，并使用配置单元UDAF：https://cwiki.apache.org/confluence/display/Hive/genericudafcaseStudy

还有非常方便的教程:http://beekeeperdata.com/posts/hadoop/2015/08/17/hive-udaf-tutorial.html