肥西县建设局资询网站,wordpress站点切换为中文,企业网站建设费用计入什么科目,神童预言新冠2023结束本文章主要分享单行函数UDF#xff08;一进一出#xff09; 现在前面大体总结#xff0c;后边文章详细介绍 自定义函数分为临时函数与永久函数 需要创建Java项目#xff0c;导入hive依赖 创建类继承 GenericUDF#xff08;自定义函数的抽象类#xff09;#xff08;实现… 本文章主要分享单行函数UDF一进一出 现在前面大体总结后边文章详细介绍 自定义函数分为临时函数与永久函数 需要创建Java项目导入hive依赖 创建类继承 GenericUDF自定义函数的抽象类实现函数 打成jar包传到服务器上 将jar包添加到hive的class path上临时生效 通过hive创建函数与Java类建立连接 目录 hive底层运行
编码
(一) 创建Java-maven项目 (1)导入hive的maven依赖
(2)创建Java类
(3)实现Java类中的方法
1.initialize
2.evaluate方法要实现函数的核心逻辑
构造hive函数:
一临时函数
二创建永久函数
hive底层运行
sql语句---》抽象语法树---》形成逻辑执行计划---》翻译成物理执行计划可以是mapreduce / spark
编码
(一) 创建Java-maven项目 (1)导入hive的maven依赖
groupIdorg.example/groupIdartifactIdhive-UDTF/artifactIdversion1.0-SNAPSHOT/version
(2)创建Java类
创建的Java类是继承自GenericUDF类抽象类
继承之后会实现3个函数initializeevaluategetDisplayString
(3)实现Java类中的方法
1.initialize
这是一个初始化方法在该函数的调用之前必须要调用一次
一般进行数据检验 public ObjectInspector initialize(ObjectInspector[] objectInspectors) throws UDFArgumentException {传入参数为ObjectInspector[] objectInspectors
ObjectInspector[] 是一个存储源信息的ObjectInspector
处理后返回一个ObjectInspector 给下一个ObjectInspector[]进行处理
//1先取上一步的源信息// 先判断参数的个数if(objectInspectors.length!1){throw new UDFArgumentLengthException(请输入1个参数);}ObjectInspector objectInspectorobjectInspectors[0];
// 判断参数是否是基本数据类型if (objectInspectors[0].getCategory()!ObjectInspector.Category.PRIMITIVE){throw new UDFArgumentLengthException(请输入一个基本数据类型);}// 假设是string类型基础数据类型在 强制类型转化进行判断//非指定类型就进行抛异常PrimitiveObjectInspector primitiveObjectInspector (PrimitiveObjectInspector) objectInspector;if (primitiveObjectInspector.getPrimitiveCategory()!PrimitiveObjectInspector.PrimitiveCategory.STRING){throw new UDFArgumentException(只接受string类型);}//返回的时候 需要找到基本数据类型的工厂 让后getInt类型return PrimitiveObjectInspectorFactory.javaIntObjectInspector;}
2.evaluate方法要实现函数的核心逻辑
每行数据调用一次 public Object evaluate(DeferredObject[] deferredObjects) throws HiveException {传入参数DeferredObject[] deferredObjects
DeferredObject[]是一个懒加载的值根据数组下标获取的值不是真值需要get一下获得真值 //DeferredObject[] deferredObjects、//获取的是每行数据中的指定列的参数不用进行校验init已完成校验否则不会调用此函数//DeferredObject[]是一个懒加载的值 需要get一下获得真值DeferredObject argdeferredObjects[0];Object o arg.get();
// o可能是空值nullif(onull){return 0;}return o.toString().length();
构造hive函数:
一临时函数
将Java编码成功后的代码进行打包package)
打包后上传服务器
将jar包添加到hive的classpath临时生效(临时函数)
add jar /opt/module/hive/datas/myudf.jar;
创建临时函数并于Java class相联
create temporary function my_len
as com.atguigu.hive.udf.MyUDF;
注意临时函数只跟会话有关系跟库没有关系。只要创建临时函数的会话不断在当前会话下任意一个库都可以使用其他会话全都不能使用。
二创建永久函数
创建永久函数前需要先将jar包上传到hdfs中在hive语句中using该路径
create function my_len2
as com.atguigu.hive.udf.MyUDF
using jar hdfs://hadoop102:8020/udf/myudf.jar;
函数的使用
select my_len2(sdsrf);
