为了满足复杂的数据开发场景,Dataphin智能研发版支持自定义Java UDF函数。本教程以Java自带函数(toLowerCase)为例,为您介绍如何基于Dataphin自定义Java UDF函数。
前提条件
背景信息
本教程基于下载的JAR包自定义的Java UDF函数,实现大写字母转换为小写字母。您也可以编写Java UDF代码,以实现更多的功能,请参见IntelliJ IDEA Java UDF开发最佳实践。
本教程中的JAR包的代码如下。
package org.alidata.odps.udf.examples;
import com.aliyun.odps.udf.UDF;
public final class javaudf extends UDF {
public String evaluate(String s) {
if (s == null) {
return null;
}
return s.toLowerCase();
}
}
其中,- JAR包路径为org.alidata.odps.udf.examples。
- class文件名为javaudf。
步骤一:上传JAR包
步骤二:创建MAXC函数
步骤三:新建SQL任务
步骤四:使用Java UDF函数
(可选)调度运维
如果需要定期的运行SQL任务,则需要配置SQL任务的调度参数并发布至生产环境,参与生产环境的调度。
- 在代码编写页面,单击页面上方的调度配置,配置调度参数,详情请参见调度配置。
- 保存、提交和发布SQL任务。