文档首页 > > 用户指南> DLI使用UDF操作指导

DLI使用UDF操作指导

分享
更新时间: 2020/02/20 GMT+08:00

操作场景

DLI支持用户使用Hive UDF(User Defined Function,用户定义函数)进行数据查询等操作。

操作步骤

  1. 编写UDF。

    根据业务需要新建或修改样例代码中SumUdDemo.java的内容。

    图1 新建或修改SumUdDemo.java的内容
  2. 生成jar包,设置输出jar包为TestUDF.jar,执行Build Artifacts。
    图2 选择Artifacts
    图3 执行Build Artifact

    在对应的路径下会生成一个TestUDF.jar,根据图2,此处的路径为:udfDemo\target\artifacts\TestUDF。

  3. 上传TestUDF.jar至OBS上。上传数据至OBS可参考提交SQL作业中“步骤2:上传数据至OBS”。
  4. 创建Function。

    在DLI Console上输入下列命令创建Function:

    CREATE FUNCTION fun1 AS 'com.huawei.demo.SumUdDemo' using jar 's3a://udf/TestUDF.jar';

  5. 使用Function。

    在查询语句中使用4中创建的Function:

    select fun1(ip) from ip_tables;

  6. 删除Function。

    如果不再使用该Function,可执行以下语句删除Function:

    Drop FUNCTION fun1;

样例代码

SumUdfDemo.java中的样例代码如下所示:

package com.huawei.demo;
  import org.apache.hadoop.hive.ql.exec.UDF;
  public class SumUdfDemo extends UDF {
    public Int evaluate(Int a, Int b) {
     return a + b;
  }
 }
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区