UDF开发插件介绍__Eclipse开发插件_工具_大数据计算服务-阿里云
在本章节我们将介绍如何使用Eclipse插件开发并在本地运行UDF。UDAF,UDTF的编写执行过程与UDF类似,均可参考UDF的示例介绍完成。ODPS Eclipse插件提供两种运行UDF的方式:菜单栏和右键单击快速运行方式。
菜单栏运行
- 从菜单栏选择Run—>Run Configurations…弹出如下对话框:
- 用户可以新建一个Run Configuration,选择运行的UDF类及类型、选择ODPS Project、填写输入表信息,如:
上述配置中,”Table”表示UDF的输入表,”Partitions”表示读取某个分区下的数据,分区由逗号分隔,“Columns”表示列,将依次作为UDF函数的参数被传入,列名由逗号分隔。
- 点击”Run”运行,运行结果将显示在控制台中:
右键单击快速运行
- 选中一个udf.java文件(比如:UDFExample.java)并单击鼠标右键,选择”Run As” -> “Run UDF|UDAF|UDTF”
- 配置信息如下:
上述配置中,”Table”表示UDF的输入表,”Partitions”表示读取某个分区下的数据,分区由逗号分隔,”Columns”表示列,将依次作为UDF函数的参数被传入,列名由逗号分隔。
- 点击”Finish”后,运行UDF,获得输出结果。
运行用户自定义UDF程序
右击一个工程并选择”New—>UDF”(或者选择菜单栏File—>New—>UDF)。
填写UDF类名然后点击”Finish”。在对应的src目录下生成与UDF类名同名的Java文件,编辑该java文件内容:
package odps;
import com.aliyun.odps.udf.UDF;
public class UserUDF extends UDF {
/**
* project: example_project
* table: wc_in1
* columns: col1,col2
*
*/
public String evaluate(String a, String b) {
return "ss2s:" + a + "," + b;
}
}
右击该java文件(如UserUDF.java),选择”Run As”,再选择”ODPS UDF|UDTF|UDAF”:
配置如下对话框:
点击”finish”,得出结果:
ss2s:A1,A2
ss2s:A1,A2
ss2s:A1,A2
ss2s:A1,A2
本示例中仅给出UDF的运行示例,UDTF的运行方式与UDF基本相同,不做特殊说明。
最后更新:2016-11-23 17:16:04
上一篇:
MapReduce开发插件介绍__Eclipse开发插件_工具_大数据计算服务-阿里云
下一篇:
Graph开发插件介绍__Eclipse开发插件_工具_大数据计算服务-阿里云
用户指南___DDoS 基础防护-阿里云
阿里云异构计算产品集结完毕 覆盖全场景AI与高性能计算需求
创建ECS Pipeline__快速开始_数据集成-阿里云
产品介绍__交通行业解决方案_大数据解决方案-阿里云
Web防护规则低中高__功能说明_Web 应用防火墙-阿里云
查询别名__alias相关_API 列表_OpenAPI 2.0_移动推送-阿里云
修改文件类型缓存策略__配置操作接口_API 手册_CDN-阿里云
查询回源流量__资源监控接口_API 手册_CDN-阿里云
Docker镜像制作__Docker_操作指南_批量计算-阿里云
2016年10月12日安全管家控制台发布__产品升级更新_安全管家服务-阿里云
相关内容
常见错误说明__附录_大数据计算服务-阿里云
发送短信接口__API使用手册_短信服务-阿里云
接口文档__Android_安全组件教程_移动安全-阿里云
运营商错误码(联通)__常见问题_短信服务-阿里云
设置短信模板__使用手册_短信服务-阿里云
OSS 权限问题及排查__常见错误及排除_最佳实践_对象存储 OSS-阿里云
消息通知__操作指南_批量计算-阿里云
设备端快速接入(MQTT)__快速开始_阿里云物联网套件-阿里云
查询API调用流量数据__API管理相关接口_API_API 网关-阿里云
使用STS访问__JavaScript-SDK_SDK 参考_对象存储 OSS-阿里云