將這個jar包命名為”my_lower.jar”。

備注：SDK的使用信息請參考UDF SDK 。

• 添加資源：在運行UDF之前，必須指定引用的UDF代碼。用戶代碼通過資源的形式添加到ODPS中。Java UDF必須被打成jar包，以jar資源添加到ODPS中，UDF框架會自動加載jar包，運行用戶自定義的UDF。 ODPS MapReduce也用到了資源這一特有概念，MapReduce文檔中對資源的使用也有闡述。

執行命令：

add jar my_lower.jar;
    -- 如果存在同名的資源請將這個jar包重命名，
    -- 並注意修改下麵示例命令中相關jar包的名字；
    -- 又或者直接使用-f選項覆蓋原有的jar資源

• 注冊UDF函數：用戶的jar包被上傳後，使得 MaxCompute 有條件自動獲取用戶代碼並運行。但此時仍然無法使用這個UDF，因為 MaxCompute 中並沒有關於這個UDF的任何信息。因此需要用戶在 MaxCompute 中注冊一個唯一的函數名，並指定這個函數名與哪個jar資源的哪個函數對應。關於如何注冊 UDF，請參考 注冊函數 。運行命令：

 CREATE FUNCTION test_lower AS org.alidata.odps.udf.examples.Lower USING my_lower.jar;

在sql中使用此函數：

select test_lower('A') from my_test_table;

UDAF示例

UDAF的注冊方式與UDF基本相同，使用方式與內建函數中得 聚合函數 相同。下麵是一個計算平均值的UDAF的代碼示例:

package org.alidata.odps.udf.examples;
import com.aliyun.odps.io.LongWritable;
import com.aliyun.odps.io.Text;
import com.aliyun.odps.io.Writable;
import com.aliyun.odps.udf.Aggregator;
import com.aliyun.odps.udf.UDFException;
/**
 * project: example_project
 * table: wc_in2
 * partitions: p2=1,p1=2
 * columns: colc,colb,cola
 */
public class UDAFExample extends Aggregator {
  @Override
  public void iterate(Writable arg0, Writable[] arg1) throws UDFException {
    LongWritable result = (LongWritable) arg0;
    for (Writable item : arg1) {
      Text txt = (Text) item;
      result.set(result.get() + txt.getLength());
    }
  }
  @Override
  public void merge(Writable arg0, Writable arg1) throws UDFException {
    LongWritable result = (LongWritable) arg0;
    LongWritable partial = (LongWritable) arg1;
    result.set(result.get() + partial.get());
  }
  @Override
  public Writable newBuffer() {
    return new LongWritable(0L);
  }
  @Override
  public Writable terminate(Writable arg0) throws UDFException {
    return arg0;
  }
}

package org.alidata.odps.udtf.examples;
import com.aliyun.odps.udf.UDTF;
import com.aliyun.odps.udf.UDTFCollector;
import com.aliyun.odps.udf.annotation.Resolve;
import com.aliyun.odps.udf.UDFException;
// TODO define input and output types, e.g., "string,string->string,bigint".
@Resolve({"string,bigint->string,bigint"})
public class MyUDTF extends UDTF {
  @Override
  public void process(Object[] args) throws UDFException {
    String a = (String) args[0];
    Long b = (Long) args[1];
    for (String t: a.split("\s+")) {
      forward(t, b);
    }
  }
}