`
zhaomengsen
  • 浏览: 196974 次
  • 性别: Icon_minigender_1
  • 来自: 河北
社区版块
存档分类
最新评论

UDF 底层实现

阅读更多
用户自定义函数
继承UDF,重写evaluate方法即可
 以 length 为例
例子如下
import org.apache.hadoop.hive.ql.exec.UDF;
public class MD5Hash extends UDF {
public String evaluate(String in) {
// 请在此实现
}
}

hive 怎么调用呢
hive 把一切操作单元 看成operater

operater 是hive 逻辑操作单位
operater
下面 fileSinkOperator
filter Operator
Groupby Operator
KeyWrapperFactory
MuxOperator
ReudceSinkOperator
SelectOperator
包含ExprNodeEvaluator[] eval
eval 通过递归调用UDF
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics