为什么用了udftype,hive还是做了谓词下推

 我来答
蔷观九382
2016-12-22 · 超过191用户采纳过TA的回答
知道小有建树答主
回答量:463
采纳率:0%
帮助的人:183万
展开全部
 最近感受了hive的udf函数的强大威力了,不仅可以使用很多已经有的udf函数,还可以自己定义符合业务场景的udf函数,下面就说一下如何写udf/udaf/udtf函数,算是一个入门介绍吧。
  First, you need to create a new class that extends UDF, with one or more methods named evaluate.
  package com.example.hive.udf;

import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;

public final class Lower extends UDF {
public Text evaluate(final Text s) {
if (s == null) { return null; }
return new Text(s.toString().toLowerCase());
}
}

  After compiling your code to a jar, you need to add this to the hive classpath.
  add jar my_jar.jar;

  Once hive is started up with your jars in the classpath, the final step is to register your function
  create temporary function my_lower as 'com.example.hive.udf.Lower';

  上面主要描述了实现一个udf的过程,首先自然是实现一个UDF函数,然后编译为jar并加入到hive的classpath中,最后创建一个临时变量名字让hive中调用。转载,仅供参考。
已赞过 已踩过<
你对这个回答的评价是?
评论 收起
推荐律师服务: 若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询

为你推荐:

下载百度知道APP,抢鲜体验
使用百度知道APP,立即抢鲜体验。你的手机镜头里或许有别人想知道的答案。
扫描二维码下载
×

类别

我们会通过消息、邮箱等方式尽快将举报结果通知您。

说明

0/200

提交
取消

辅 助

模 式