2016 - 2024

感恩一路有你

hive udf函数编写 hive自定义udf函数,在udf函数内怎么读取hive表数据?

浏览量:1879 时间:2021-03-13 20:06:51 作者:admin

hive自定义udf函数,在udf函数内怎么读取hive表数据?

最近,我感觉到蜂巢的自定义项功能强大的力量。我不仅可以使用许多现有的自定义项函数,还可以根据业务场景定义自定义项函数。现在我们来谈谈如何编写UDF/udaf/udtf函数,这可以看作是一个介绍。

首先,您需要创建一个扩展UDF的新类,其中包含一个或多个名为evaluate的方法。

packagecom.example.hive配置单元.udf

导入org.apache.hadoop下载. 配置单元.ql.exec.UDF

导入org.apache.hadoop下载. io.文本

public final class Lower extends UDF{

public Text evaluate(final Text s){

if(s==null){return null}

return new Text(s.toString().toLowerCase())

}

将代码编译到jar后,需要将其添加到配置单元类路径。

add jar myujar.jar文件

一旦蜂巢启动,您的jars在类路径中,最后一步是注册你的函数

创建临时函数mylower as“com.example.hive配置单元. 自定义项下限上面主要描述了实现自定义项的过程。首先,实现一个UDF函数是很自然的,然后将它编译成jar并添加到hive的类路径中,最后创建一个临时变量名在hive中调用。重印仅供参考。

hive udf函数编写 hive的udf函数有哪些 hive自定义udf实例

版权声明:本文内容由互联网用户自发贡献,本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。