开发者社区> 问答> 正文

MaxCompute工具及下载:Eclipse开发插件:UDF开发插件介绍



在本章节我们将介绍如何使用Eclipse插件开发并在本地运行UDF。UDAF,UDTF的编写执行过程与UDF类似,均可参考UDF的示例介绍完成。ODPS Eclipse插件提供两种运行UDF的方式:菜单栏和右键单击快速运行方式。

菜单栏运行

  1. 从菜单栏选择Run—>Run Configurations…弹出如下对话框:

  1. 用户可以新建一个Run Configuration,选择运行的UDF类及类型、选择ODPS Project、填写输入表信息,如:  

  
上述配置中,”Table”表示UDF的输入表,”Partitions”表示读取某个分区下的数据,分区由逗号分隔,“Columns”表示列,将依次作为UDF函数的参数被传入,列名由逗号分隔。
  1. 点击”Run”运行,运行结果将显示在控制台中:



右键单击快速运行

  1. 选中一个udf.java文件(比如:UDFExample.java)并单击鼠标右键,选择”Run As” -> “Run UDF|UDAF|UDTF”

  1. 配置信息如下:  

  
上述配置中,”Table”表示UDF的输入表,”Partitions”表示读取某个分区下的数据,分区由逗号分隔,”Columns”表示列,将依次作为UDF函数的参数被传入,列名由逗号分隔。
  1. 点击”Finish”后,运行UDF,获得输出结果。  


运行用户自定义UDF程序


右击一个工程并选择”New—>UDF”(或者选择菜单栏File—>New—>UDF)。
填写UDF类名然后点击”Finish”。在对应的src目录下生成与UDF类名同名的Java文件,编辑该java文件内容:
  1. package odps;
  2. import com.aliyun.odps.udf.UDF;
  3. public class UserUDF extends UDF {
  4.       /**
  5.        * project: example_project
  6.        * table: wc_in1
  7.        * columns: col1,col2
  8.        *
  9.        */
  10.       public String evaluate(String a, String b) {
  11.         return "ss2s:" + a + "," + b;
  12.       }
  13. }

右击该java文件(如UserUDF.java),选择”Run As”,再选择”ODPS UDF|UDTF|UDAF”:

配置如下对话框:  

点击”finish”,得出结果:
  1. ss2s:A1,A2
  2. ss2s:A1,A2
  3. ss2s:A1,A2
  4. ss2s:A1,A2

本示例中仅给出UDF的运行示例,UDTF的运行方式与UDF基本相同,不做特殊说明。

展开
收起
行者武松 2017-10-24 14:36:05 1921 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Data+AI时代大数据平台应该如何建设 立即下载
大数据AI一体化的解读 立即下载
极氪大数据 Serverless 应用实践 立即下载

相关镜像