367      小米6  小米路由器

UDF開發插件介紹__Eclipse開發插件_工具_大數據計算服務-阿裏雲

在本章節我們將介紹如何使用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文件內容：

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;
      }
}

ss2s:A1,A2
ss2s:A1,A2
ss2s:A1,A2
ss2s:A1,A2