自定义函数用的最多的是单行函数，所以这里只介绍自定义单行函数。
Coding
导入依赖
<dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-exec</artifactId> <version>3.1.3</version> </dependency>
编写代码
import org.apache.hadoop.hive.ql.exec.UDFArgumentException; import org.apache.hadoop.hive.ql.exec.UDFArgumentTypeException; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.ql.udf.generic.GenericUDF; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector; import org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector; import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory; public class MyUDF extends GenericUDF { /** * 开始处理 SQL 之前执行一次,这里我们对参数做一个判断 * @param arguments 检查传进来的参数 inspector: 检察员,鉴别器 * @return * @throws UDFArgumentException */ @Override public ObjectInspector initialize(ObjectInspector[] arguments) throws UDFArgumentException { // 判断参数的个数 if (arguments.length != 1){ throw new UDFArgumentException("只接受一个参数"); } ObjectInspector argument = arguments[0]; // 判断参数的类型 primitive:原始类型（int、char、boolean等） category: 类别 if (!argument.getCategory().equals(ObjectInspector.Category.PRIMITIVE)){ throw new UDFArgumentTypeException(1,"只接受基本类型的参数"); } // 参数类型直接受 String 类型 PrimitiveObjectInspector primitiveObjectInspector = (PrimitiveObjectInspector) argument; if (primitiveObjectInspector.getPrimitiveCategory() != PrimitiveObjectInspector.PrimitiveCategory.STRING){ throw new UDFArgumentException("只接受String类型的参数"); } // 函数本身返回 int 需要返回int类型的鉴别器对象 return PrimitiveObjectInspectorFactory.javaIntObjectInspector; } /** * 函数的逻辑处理,每处理一行数据就调用一次这个方法 * 注意: 是一行数据 * @param arguments 输入参数 * @return 返回值 * @throws HiveException */ @Override public Object evaluate(DeferredObject[] arguments) throws HiveException { if (arguments[0].get()==null){ return 0; } return arguments[0].get().toString().length(); } /** * 获取在执行计划中展示的字符串 * explain HQL * 这个不用实现，直接返回空字符串即可 */ @Override public String getDisplayString(String[] strings) { return ""; } }
创建临时函数
（1）打成jar包上传到服务器/opt/module/hive/datas/myudf.jar
（2）将jar包添加到hive的classpath，临时生效
hive (default)> add jar /opt/module/hive/datas/myudf.jar;
（3）创建临时函数与开发好的java class关联
hive (default)> create temporary function my_len as “MyUDF”;（要求是全类名，这里我的类直接在java目录下）
（4）即可在hql中使用自定义的临时函数
hive (default)> select my_len("hello world");
（5）删除临时函数
hive (default)> drop temporary function my_len;
注意：临时函数只跟会话有关系，跟库没有关系。只要创建临时函数的会话不断，在当前会话下，任意一个库都可以使用，其他会话全都不能使用。
创建永久函数
add jar 是临时生效，所以在创建永久函数的时候，需要指定路径（因为永久函数是存储在Hive Metastore中的函数，可以在多个查询和会话中共享和重用。通过将JAR文件存储在HDFS上，并确保Hive可以访问该路径，可以方便地共享和使用这些函数。）
指定using jar为HDFS路径的好处包括：
- 共享性：HDFS是Hadoop分布式文件系统，可以在集群中的多个节点之间共享数据。将JAR文件存储在HDFS上，可以使得Hive函数在集群中的任何节点上都可以访问和使用。
- 可靠性：HDFS具有高度的容错性和可靠性，可以确保JAR文件的可用性和持久性。即使某个节点发生故障，JAR文件也可以从其他节点恢复。
- 一致性：通过在HDFS上存储JAR文件，可以确保所有Hive会话和查询都使用相同版本的函数代码。这有助于维护数据一致性和结果的一致性。
上传 jar 包到 HDFS ：
create function my_len as "MyUDF" using jar "hdfs://hadoop102:8020/udf/myudf.jar";
测试使用效果：
show functions like "*my_len"
注意：永久函数跟会话没有关系，创建函数的会话断了以后，其他会话也可以使用。
永久函数使用的时候，需要在指定的库里面操作,或者在其他库里面使用的话加上 库名.函数名
